一、cancel 方法

boolean cancel(boolean mayInterruptIfRunning);
  • cancel 方法用于取消异步任务的执行
参数值说明
true如果任务正在执行，中断任务
false如果任务正在执行，不会中断任务；如果任务还未开始，中断任务
返回值说明
true任务取消成功
false任务取消失败，任务已经完成、已经被取消等

二、cancel 方法实例

1、任务执行中进行中断
ExecutorService executorService = Executors.newSingleThreadExecutor();

Future<?> future = executorService.submit(() -> {
    Scanner scanner = new Scanner(System.in);
    while (true) {
        System.out.println("请输入一个整数：");
        int num = scanner.nextInt();

        if (Thread.currentThread().isInterrupted()) {
            System.out.println("任务被中断");
            break;
        }

        System.out.println("输入的整数是：" + num);
    }
});

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

boolean result = 【在这里中断任务】
System.out.println("中断结果：" + result);
  1. 调用 future.cancel(true)，输出结果如下
请输入一个整数：
中断结果：true
12
任务被中断
  1. 调用 future.cancel(false)，输出结果如下
请输入一个整数：
中断结果：true
12
输入的整数是：12
请输入一个整数：
2、任务执行完成后进行中断
ExecutorService executorService = Executors.newSingleThreadExecutor();

Future<?> future = executorService.submit(() -> {
    System.out.println("任务执行");
});

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

boolean result = 【在这里中断任务】
System.out.println("中断结果：" + result);
  1. 调用 future.cancel(true)，输出结果如下
任务执行
中断结果：false
  1. 调用 future.cancel(false)，输出结果如下
任务执行
中断结果：false
3、任务执行前进行中断
ExecutorService executorService = Executors.newSingleThreadExecutor();

executorService.submit(() -> {
    System.out.println("任务 1 开始执行");
    try {
        Thread.sleep(5 * 1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("任务 1 执行完成");
});

Future<?> future = executorService.submit(() -> {
    System.out.println("任务 2 开始执行");
    System.out.println("任务 2 执行完成");
});

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

boolean result = 【在这里中断任务】
System.out.println("中断结果：" + result);
  1. 调用 future.cancel(true)，输出结果如下
任务 1 开始执行
中断结果：true
任务 1 执行完成
  1. 调用 future.cancel(false)，输出结果如下
任务 1 开始执行
中断结果：true
任务 1 执行完成
4、任务异常后进行中断
ExecutorService executorService = Executors.newSingleThreadExecutor();

Future<?> future = executorService.submit(() -> {
    System.out.println("任务开始执行");
    int a = 10 / 0;
    System.out.println("任务执行完成");
});

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

boolean result = 【在这里中断任务】
System.out.println("中断结果：" + result);
  1. 调用 future.cancel(true)，输出结果如下
任务开始执行
中断结果：false
  1. 调用 future.cancel(false)，输出结果如下
任务开始执行
中断结果：false
5、任务中断后进行中断
ExecutorService executorService = Executors.newSingleThreadExecutor();

Future<?> future = executorService.submit(() -> {
    System.out.println("任务开始执行");
    try {
        Thread.sleep(5 * 1000);
    } catch (InterruptedException e) {
        System.out.println("任务被中断");
        throw new RuntimeException(e);
    }
    System.out.println("任务执行完成");
});

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

boolean result = future.cancel(true);
System.out.println("中断结果：" + result);

boolean result2 = 【在这里再次中断任务】
System.out.println("再次中断结果：" + result2);
  1. 调用 future.cancel(true)，输出结果如下
任务开始执行
任务被中断
中断结果：true
再次中断结果：false
  1. 调用 future.cancel(false)，输出结果如下
任务开始执行
任务被中断
中断结果：true
再次中断结果：false
小结
-future.cancel(true)future.cancel(false)
任务执行前truetrue
任务执行中truetrue
任务执行完成后falsefalse
任务异常后falsefalse
任务中断后falsefalse

三、isCancelled 方法与 isDone 方法

  1. isCancelled 方法用于检查任务是否被取消
boolean isCancelled();
  1. isDone 方法用于检查任务是否完成
boolean isDone();

四、isCancelled 方法与 isDone 方法实例

1、任务执行中 + 任务执行中进行中断
ExecutorService executorService = Executors.newSingleThreadExecutor();

Future<?> future = executorService.submit(() -> {
    Scanner scanner = new Scanner(System.in);
    while (true) {
        System.out.println("请输入一个整数：");
        int num = scanner.nextInt();

        if (Thread.currentThread().isInterrupted()) {
            System.out.println("任务被中断");
            break;
        }

        System.out.println("输入的整数是：" + num);
    }
});

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

boolean cancelled = future.isCancelled();
System.out.println("任务是否被取消：" + cancelled);
boolean done = future.isDone();
System.out.println("任务是否完成：" + done);

boolean result = 【在这里中断任务】
System.out.println("中断结果：" + result);

boolean cancelled2 = future.isCancelled();
System.out.println("任务是否被取消：" + cancelled2);
boolean done2 = future.isDone();
System.out.println("任务是否完成：" + done2);
  1. 调用 future.cancel(true)，输出结果如下
请输入一个整数：
任务是否被取消：false
任务是否完成：false
中断结果：true
任务是否被取消：true
任务是否完成：true
12
任务被中断
  1. 调用 future.cancel(false)，输出结果如下
请输入一个整数：
任务是否被取消：false
任务是否完成：false
中断结果：true
任务是否被取消：true
任务是否完成：true
12
输入的整数是：12
请输入一个整数：
2、任务执行完成后 + 任务执行完成后进行中断
ExecutorService executorService = Executors.newSingleThreadExecutor();

Future<?> future = executorService.submit(() -> {
    System.out.println("任务执行");
});

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

boolean cancelled = future.isCancelled();
System.out.println("任务是否被取消：" + cancelled);
boolean done = future.isDone();
System.out.println("任务是否完成：" + done);

boolean result = 【在这里中断任务】
System.out.println("中断结果：" + result);

boolean cancelled2 = future.isCancelled();
System.out.println("任务是否被取消：" + cancelled2);
boolean done2 = future.isDone();
System.out.println("任务是否完成：" + done2);
  1. 调用 future.cancel(true)，输出结果如下
任务执行
任务是否被取消：false
任务是否完成：true
中断结果：false
任务是否被取消：false
任务是否完成：true
  1. 调用 future.cancel(false)，输出结果如下
任务执行
任务是否被取消：false
任务是否完成：true
中断结果：false
任务是否被取消：false
任务是否完成：true
3、任务执行前 + 任务执行前进行中断
ExecutorService executorService = Executors.newSingleThreadExecutor();

executorService.submit(() -> {
    System.out.println("任务 1 开始执行");
    try {
        Thread.sleep(5 * 1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("任务 1 执行完成");
});

Future<?> future = executorService.submit(() -> {
    System.out.println("任务 2 开始执行");
    System.out.println("任务 2 执行完成");
});

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

boolean cancelled = future.isCancelled();
System.out.println("任务是否被取消：" + cancelled);
boolean done = future.isDone();
System.out.println("任务是否完成：" + done);

boolean result = 【在这里中断任务】
System.out.println("中断结果：" + result);

boolean cancelled2 = future.isCancelled();
System.out.println("任务是否被取消：" + cancelled2);
boolean done2 = future.isDone();
System.out.println("任务是否完成：" + done2);
  1. 调用 future.cancel(true)，输出结果如下
任务 1 开始执行
任务是否被取消：false
任务是否完成：false
中断结果：true
任务是否被取消：true
任务是否完成：true
任务 1 执行完成
  1. 调用 future.cancel(false)，输出结果如下
任务 1 开始执行
任务是否被取消：false
任务是否完成：false
中断结果：true
任务是否被取消：true
任务是否完成：true
任务 1 执行完成
4、任务异常后 + 任务异常后进行中断
ExecutorService executorService = Executors.newSingleThreadExecutor();

Future<?> future = executorService.submit(() -> {
    System.out.println("任务开始执行");
    int a = 10 / 0;
    System.out.println("任务执行完成");
});

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

boolean cancelled = future.isCancelled();
System.out.println("任务是否被取消：" + cancelled);
boolean done = future.isDone();
System.out.println("任务是否完成：" + done);

boolean result = 【在这里中断任务】
System.out.println("中断结果：" + result);

boolean cancelled2 = future.isCancelled();
System.out.println("任务是否被取消：" + cancelled2);
boolean done2 = future.isDone();
System.out.println("任务是否完成：" + done2);
  1. 调用 future.cancel(true)，输出结果如下
任务开始执行
任务是否被取消：false
任务是否完成：true
中断结果：false
任务是否被取消：false
任务是否完成：true
  1. 调用 future.cancel(false)，输出结果如下
任务开始执行
任务是否被取消：false
任务是否完成：true
中断结果：false
任务是否被取消：false
任务是否完成：true
小结
-isCancelled()isDone()
任务执行前falsefalse
任务执行中falsefalse
任务执行完成后falsetrue
任务异常后falsetrue
任务执行前进行中断truetrue
任务执行中进行中断truetrue
任务执行完成后进行中断falsetrue
任务异常后进行中断falsetrue
# java # 开发语言 # 学习方法 # 学习 # java-ee # intellij-idea # intellij idea
Logo
AI Agent技术社区

Agent 垂直技术社区，欢迎活跃、内容共建。

更多推荐

cover

别让你的 Agent 一口吃成胖子：AI Agent 任务拆分的工程实践指南

avatar AI Agent技术社区
cover

AI Agent律师行业智能体的实践步骤

avatar AI Agent技术社区

MCP + 企业IM架构：AI Agent调用OA、ERP、MES时，身份和权限如何传递？

<think>我们只需要根据内容生成摘要，不超过150字。先理解文章核心：MCP+企业IM架构，AI Agent调用OA/ERP/MES时身份和权限传递。要点：IM从消息入口变任务入口；MCP解决连接，但不解决权限；需要五层身份映射；权限分层（可见性、调用、数据范围、确认）；建议组合MCP+API网关。摘要需简洁。 参考生成： "本文探讨MCP与企业IM集成中AI Agent调用业务系统时的身份权

avatar AI Agent技术社区