在Java中,要取消一个FutureTask任务,你需要调用Future.cancel()方法。这个方法接受一个布尔参数mayInterruptIfRunning,用于指示是否允许中断正在运行的任务。
以下是一个简单的示例,展示了如何使用FutureTask和cancel()方法取消任务:
import java.util.concurrent.*;
public class Main {
public static void main(String[] args) {
// 创建一个Callable任务
Callable task = () -> {
Thread.sleep(5000); // 模拟一个耗时任务
return "Task completed";
};
// 将Callable任务包装成FutureTask
FutureTask futureTask = new FutureTask<>(task);
// 提交FutureTask到线程池
ExecutorService executorService = Executors.newSingleThreadExecutor();
executorService.submit(futureTask);
try {
// 等待一段时间后取消任务
Thread.sleep(2000);
boolean isCancelled = futureTask.cancel(true); // 设置mayInterruptIfRunning为true以允许中断
if (isCancelled) {
System.out.println("Task cancelled.");
} else {
System.out.println("Task not cancelled.");
}
} catch (InterruptedException e) {
System.out.println("Main thread interrupted.");
} finally {
// 关闭线程池
executorService.shutdown();
}
}
}
在这个示例中,我们创建了一个Callable任务,然后将其包装成FutureTask。接着,我们将FutureTask提交给一个线程池。在等待了2秒后,我们调用futureTask.cancel(true)来取消任务。如果任务被取消,isCancelled将为true,否则为false。最后,我们关闭线程池。
需要注意的是,如果任务已经开始执行(即running状态),那么cancel()方法会尝试中断任务。如果任务已经完成、已经取消或者由于其他原因而无法中断,那么cancel()方法将返回false。
以上就是关于“JavaFutureTask如何取消任务”的相关介绍,筋斗云是国内较早的云主机应用的服务商,拥有10余年行业经验,提供丰富的云服务器、租用服务器等相关产品服务。云服务器资源弹性伸缩,主机vCPU、内存性能强悍、超高I/O速度、故障秒级恢复;电子化备案,提交快速,专业团队7×24小时服务支持!
简单好用、高性价比云服务器租用链接:https://www.jindouyun.cn/product/cvm