![\"\u53d6\u6d88\u53e5\u67c4\u4e0e\u505c\u6b62\u4e1a\u52a1\u52a8\u4f5c\u7684\u8fb9\u754c\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/10\/20261029214848-6ae3bf408824d.png\")
<\/p>\n<\/p>\n
Agent \u8d85\u65f6\u540e\u8c03\u7528 future.cancel(true)，\u8fd4\u56de true，\u63a5\u7740\u628a\u8ba2\u5355\u72b6\u6001\u6539\u6210\u201c\u6267\u884c\u5931\u8d25\u201d\u3002\u8fd9\u6761\u94fe\u8def\u85cf\u7740\u4e00\u4e2a\u8bef\u5224：Future \u7684\u53d6\u6d88\u72b6\u6001，\u63cf\u8ff0\u7684\u662f\u7ed3\u679c\u53e5\u67c4；\u5de5\u4f5c\u7ebf\u7a0b\u6709\u6ca1\u6709\u54cd\u5e94\u4e2d\u65ad\u3001\u8fdc\u7aef\u6709\u6ca1\u6709\u63d0\u4ea4，\u662f\u53e6\u5916\u4e24\u4ef6\u4e8b\u3002<\/p>\n
\u8fd9\u4e2a\u95ee\u9898\u4e0d\u4f1a\u56e0\u4e3a\u6362\u6210\u865a\u62df\u7ebf\u7a0b\u81ea\u52a8\u6d88\u5931\u3002Java 24 \u7684 StructuredTaskScope \u4ecd\u662f\u9884\u89c8 API，\u9700\u8981\u76f8\u5e94\u7f16\u8bd1\u548c\u8fd0\u884c\u9009\u9879\u3002\u5176\u6587\u6863\u533a\u5206\u5f97\u5f88\u6e05\u695a：shutdown \u4f1a\u4e2d\u65ad\u672a\u5b8c\u6210\u5b50\u4efb\u52a1，\u4f46\u4e0d\u7b49\u5f85\u5b83\u4eec\u505c\u6b62；close \u4f1a\u7b49\u5f85\u5269\u4f59\u7ebf\u7a0b\u7ed3\u675f\u3002joinUntil \u7684\u622a\u6b62\u65f6\u95f4\u56e0\u6b64\u4e0d\u80fd\u76f4\u63a5\u89e3\u91ca\u6210\u6574\u4e2a\u4f5c\u7528\u57df\u7684\u7269\u7406\u9000\u51fa\u4e0a\u9650\u3002<\/p>\n
\u4ee5\u4e0b\u4ee3\u7801\u6545\u610f\u8ba9\u5de5\u4f5c\u8005\u5ffd\u7565\u4e2d\u65ad，\u76f4\u5230\u6d4b\u8bd5\u91ca\u653e\u95e8\u95e9\u3002\u5b83\u4e0d\u662f\u63a8\u8350\u7684\u4e1a\u52a1\u5199\u6cd5，\u800c\u662f\u7528\u6765\u8bc1\u660e\u201c\u53d6\u6d88\u6210\u529f\u201d\u4e0d\u7b49\u4e8e\u201c\u526f\u4f5c\u7528\u5df2\u963b\u6b62\u201d\u3002\u4fdd\u5b58\u4e3a CancelBoundary.java，\u8fd0\u884c java CancelBoundary.java\u3002<\/p>\n
import java.util.concurrent.*;
\nimport java.util.concurrent.atomic.AtomicInteger;<\/p>\n
public class CancelBoundary {
\n static void check(boolean value, String reason) {
\n if (!value) throw new AssertionError(reason);
\n }
\n public static void main(String[] args) throws Exception {
\n ExecutorService pool = Executors.newSingleThreadExecutor();
\n CountDownLatch started = new CountDownLatch(1);
\n CountDownLatch release = new CountDownLatch(1);
\n CountDownLatch finished = new CountDownLatch(1);
\n AtomicInteger committed = new AtomicInteger();
\n Future<?> f = pool.submit(() -> {
\n started.countDown();
\n boolean released = false;
\n while (!released) {
\n try {
\n release.await();
\n released = true;
\n } catch (InterruptedException ignored) {
\n \/\/ \u4ec5\u7528\u4e8e\u53cd\u4f8b：\u5b9e\u9645\u4e1a\u52a1\u4e0d\u5e94\u7167\u642c\u8fd9\u79cd\u541e\u6389\u4e2d\u65ad\u7684\u5faa\u73af\u3002
\n }
\n }
\n committed.incrementAndGet();
\n finished.countDown();
\n });
\n try {
\n check(started.await(2, TimeUnit.SECONDS), "worker not started");
\n check(f.cancel(true), "future was not cancelled");
\n try {
\n f.get();
\n throw new AssertionError("cancelled result must not be returned");
\n } catch (CancellationException expected) {
\n check(committed.get() == 0, "gate must still block action");
\n }
\n release.countDown();
\n check(finished.await(2, TimeUnit.SECONDS), "worker did not finish");
\n check(committed.get() == 1, "action can occur after cancellation");
\n System.out.println("cancelled handle; worker action still occurred");
\n } finally {
\n release.countDown();
\n pool.shutdownNow();
\n check(pool.awaitTermination(2, TimeUnit.SECONDS), "pool still running");
\n }
\n }
\n}<\/p>\n
![\"\u53d6\u6d88\u3001\u4e2d\u65ad\u4e0e\u8fdc\u7aef\u56de\u6267\u5206\u522b\u89c2\u6d4b\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/10\/20261029214850-6ae3bf42d2eaa.png\")
<\/p>\n
\u8fd9\u4e2a\u4f8b\u5b50\u5728\u672c\u5730 JDK 12 \u8fd0\u884c\u901a\u8fc7，\u6ca1\u6709\u542f\u52a8 Java 24 \u865a\u62df\u7ebf\u7a0b，\u6ca1\u6709\u6570\u636e\u5e93\u4e8b\u52a1，\u4e5f\u6ca1\u6709\u9000\u6b3e\u8bf7\u6c42\u3002\u8ba1\u6570\u5668\u4ec5\u4ee3\u8868\u4e00\u4e2a\u53ef\u89c2\u5bdf\u52a8\u4f5c\u3002\u6d4b\u8bd5\u4e2d\u7684\u95e8\u95e9\u4fdd\u8bc1\u4e8b\u4ef6\u987a\u5e8f，\u907f\u514d\u9760 sleep \u731c\u6d4b\u7ebf\u7a0b\u4f55\u65f6\u6267\u884c\u3002<\/p>\n
\u53ea\u8bfb\u641c\u7d22\u8d85\u65f6，\u53ef\u4ee5\u8bf4\u660e\u672c\u8f6e\u6ca1\u6709\u53d6\u5f97\u7ed3\u679c\u3002\u9000\u6b3e\u3001\u6263\u6b3e\u3001\u53d1\u6d88\u606f\u8fd9\u7c7b\u52a8\u4f5c\u8d85\u65f6，\u5982\u679c\u6ca1\u6709\u6743\u5a01\u56de\u6267，\u5e94\u8fdb\u5165\u201c\u7ed3\u679c\u5f85\u6838\u5b9e\u201d，\u800c\u4e0d\u662f\u7acb\u523b\u91cd\u65b0\u6267\u884c\u6216\u5ba3\u5e03\u5931\u8d25\u3002\u540e\u7eed\u7528\u7a33\u5b9a\u4e1a\u52a1\u952e\u67e5\u8be2\u72b6\u6001；\u771f\u6b63\u91cd\u8bd5\u524d，\u8fd8\u9700\u8981\u670d\u52a1\u7aef\u5e42\u7b49\u8bed\u4e49\u3002<\/p>\n
\u5728\u7ebf\u7a0b\u5185\u90e8，\u6355\u83b7 InterruptedException \u540e\u901a\u5e38\u5e94\u9000\u51fa\u3001\u5411\u4e0a\u629b\u51fa，\u6216\u5728\u65e0\u6cd5\u7acb\u5373\u9000\u51fa\u65f6\u6062\u590d\u4e2d\u65ad\u6807\u8bb0\u5e76\u6309\u534f\u8bae\u6536\u5c3e；\u4e0d\u80fd\u628a\u4e2d\u65ad\u5f53\u4f5c\u64a4\u9500\u5916\u90e8\u4e8b\u52a1\u7684\u673a\u5236\u3002\u5bf9\u5173\u95ed\u9636\u6bb5\u4e5f\u8981\u8bbe\u8ba1\u76d1\u63a7\u548c\u9694\u79bb\u9884\u7b97：\u5982\u679c\u5e95\u5c42\u5e93\u4e0d\u54cd\u5e94\u4e2d\u65ad，\u7ed3\u6784\u5316\u5e76\u53d1\u63d0\u4f9b\u7684\u751f\u547d\u5468\u671f\u7ea6\u675f\u53ef\u80fd\u8868\u73b0\u4e3a\u8c03\u7528\u8005\u7ee7\u7eed\u7b49\u5f85\u3002<\/p>\n
\u865a\u62df\u7ebf\u7a0b\u964d\u4f4e\u7684\u662f\u67d0\u4e9b\u963b\u585e\u5e76\u53d1\u7684\u627f\u8f7d\u6210\u672c\u3002\u5b83\u4e0d\u66ff\u6211\u4eec\u5b9a\u4e49\u201c\u4ec0\u4e48\u65f6\u5019\u53ef\u4ee5\u8bf4\u8fd9\u7b14\u4e1a\u52a1\u6ca1\u6709\u53d1\u751f\u201d\u3002<\/p>\n
\u53c2\u8003：Java 24 StructuredTaskScope \u7684 shutdown\u3001joinUntil \u4e0e close\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
Agent \u8d85\u65f6\u540e\u8c03\u7528 future.cancel(true)，\u8fd4\u56de true，\u63a5\u7740\u628a\u8ba2\u5355\u72b6\u6001\u6539\u6210\u201c\u6267\u884c\u5931\u8d25\u201d\u3002\u8fd9\u6761\u94fe\u8def\u85cf\u7740\u4e00\u4e2a\u8bef\u5224：Future \u7684\u53d6\u6d88\u72b6\u6001，\u63cf\u8ff0\u7684\u662f\u7ed3\u679c\u53e5\u67c4；\u5de5\u4f5c\u7ebf\u7a0b\u6709\u6ca1\u6709\u54cd\u5e94\u4e2d\u65ad\u3001\u8fdc\u7aef\u6709\u6ca1\u6709\u63d0\u4ea4，\u662f\u53e6\u5916\u4e24\u4ef6\u4e8b\u3002
\n\u8fd9\u4e2a\u95ee\u9898\u4e0d\u4f1a\u56e0\u4e3a\u6362\u6210\u865a\u62df\u7ebf\u7a0b\u81ea\u52a8\u6d88\u5931\u3002Java 24 \u7684 StructuredTaskScope \u4ecd\u662f\u9884\u89c8 API，\u9700\u8981\u76f8\u5e94\u7f16\u8bd1\u548c\u8fd0\u884c\u9009\u9879\u3002\u5176\u6587\u6863<\/p>\n","protected":false},"author":2,"featured_media":119684,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[13654,13655,13653,13656,13468],"topic":[],"class_list":["post-119686","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-future","tag-interruptedexception","tag-java","tag-structuredtaskscope","tag-13468"],"yoast_head":"\n