温馨提示×

java newfixedthreadpool能取消任务吗

小樊
81
2024-11-26 15:02:22
栏目: 编程语言

是的,您可以使用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。最后,我们关闭线程池。

0