温馨提示×

java threadpoolexecutor能实现任务取消吗

小樊
81
2024-11-16 23:49:54
栏目: 编程语言

是的,Java的ThreadPoolExecutor可以取消任务。你可以使用Future.cancel()方法来取消一个任务。当你提交一个任务给ThreadPoolExecutor时,它会返回一个Future对象,你可以使用这个对象来取消任务。

以下是一个简单的示例:

import java.util.concurrent.*;

public class ThreadPoolExecutorCancelTaskExample {
    public static void main(String[] args) {
        // 创建一个线程池
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                3, 5, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()
        );

        // 提交一个任务并获取Future对象
        Future<?> future = executor.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.");
        }

        // 关闭线程池
        executor.shutdown();
    }
}

在这个示例中,我们创建了一个ThreadPoolExecutor,提交了一个任务,并在任务开始执行后取消了它。future.cancel(true)方法尝试取消任务,如果任务已经被取消或者由于其他原因无法取消,它将返回false

0