是的,您可以使用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
。最后,我們關閉線程池。