是的,您可以使用java.util.concurrent.Executors
类中的newFixedThreadPool
方法创建一个固定大小的线程池,并使用Future
对象取消任务。以下是一个简单的示例:
import java.util.concurrent.*;
public class FixedThreadPoolCancelTask {
public static void main(String[] args) {
// 创建一个固定大小为3的线程池
ExecutorService executorService = Executors.newFixedThreadPool(3);
// 提交任务并获取Future对象
Future<?> future = executorService.submit(() -> {
try {
System.out.println("Task started.");
Thread.sleep(10000); // 模拟长时间运行的任务
System.out.println("Task completed.");
} catch (InterruptedException e) {
System.out.println("Task interrupted.");
}
});
// 取消任务
boolean isCancelled = future.cancel(true);
if (isCancelled) {
System.out.println("Task cancelled.");
} else {
System.out.println("Task not cancelled.");
}
// 关闭线程池
executorService.shutdown();
}
}
在这个示例中,我们创建了一个固定大小为3的线程池,并提交了一个长时间运行的任务。然后,我们使用future.cancel(true)
方法取消任务。如果任务被取消,isCancelled
将为true
,否则为false
。最后,我们关闭线程池。