求助 CompletableFuture 怎么取消其任务

[mengjisang]

查询到 cancel 方法其原型为

    /* ------------- Control and status methods -------------- */

    /**
     * If not already completed, completes this CompletableFuture with
     * a {@link CancellationException}. Dependent CompletableFutures
     * that have not already completed will also complete
     * exceptionally, with a {@link CompletionException} caused by
     * this {@code CancellationException}.
     *
     * @param mayInterruptIfRunning this value has no effect in this
     * implementation because interrupts are not used to control
     * processing.
     *
     * @return {@code true} if this task is now cancelled
     */
    public boolean cancel(boolean mayInterruptIfRunning) {
        boolean cancelled = (result == null) &&
            internalComplete(new AltResult(new CancellationException()));
        postComplete();
        return cancelled || isCancelled();
    }

mayInterruptIfRunning 参数实际并没有被用到，取消操作实际是软取消，并不会直接从线程池中进行取消操作， 实际测试发现 cancel 确实有问题，没有按照想象中快速取消超时任务，最终会导致线程池阻塞，不知道该怎么办

[BBCCBB]

线程已经开始执行, 又没有可以被 interupt 的操作, 是取消不了的. 取消只是一个信号通知, 要代码里有响应才行.

线程跑到一半, 也不能直接把线程 destory 了不是?

[mengjisang]

@BBCCBB 大概明白了，这个 cancel 方法，似乎就是设置了一下内部状态，然后抛出 CancellationException 异常

[xiaofan2]

取消都是通知操作 无论是线程池还是其他的业务场景 真正要不要获取这种信号以及如何处理应该由业务逻辑处理 你看看 InterruptException

[inter12]

1.把线程放到一个上下文中
2.在线程逻辑里面放置一个钩子
3.触发这个钩子

[guyeu]

你的目的是不要线程池阻塞？这里的阻塞不是一个很清晰的表述，假如它是指避免一个任务长期占用线程：
1. 对于计算密集型任务，唯一实际可用的办法是在逻辑里去检查线程的内部状态然后按照业务去处理（早期版本可以用一个叫`Thread.stop`的方法来暴力停止，但这不是一个生产可用的选项）；
2. 对于 IO 密集型任务，合理的实现都会响应`interrupt`信号，因此`cancel`方法就足够了。

实际上，更常见的需求是避免任务堆积导致内存压力，这种情况下：
1. 限制阻塞队列的长度，并设计合理的拒绝策略；
2. 解决资源瓶颈，缺 CPU 就加 CPU ，缺消费者就增加消费者节点。

[wolfie]

interrupt 是多线程通信的一个标记，没开始的任务可以终止。
建议贴出原始需求。

[boywang004]

Java 之所以是比较安全的语言，就是这样设计的……你可以让一个线程「去死」，但是人家愿意不愿意死，甚至愿意不愿意理你，都是人家的自由。我见过太多开发者不正确的处理 InterruptedException 了。这样的代码如果你尝试 cancel(true)，就坐等杯具了。

[Karte]

Interrupted 会告知线程当前是否被中断, 需要在 run() 方法中判断. 如果没有判断这个通知就是无效的, 线程依旧会执行. 还有如果收到了 interrupted 中断, 建议手动再次执行 `Thread.currentThread().interrupt();`, 这样可以让上层感知到线程被中断了.

[mengjisang]

结论就是，CompletableFuture 能中断那些没有被放入线程池执行的任务，已经执行的会抛出中断信号，但是线程内的任务何时退出则取决于任务执行情况和线程池的调度。

因为，最后我用了 ReentrantLock 来保证每次只有一个线程去执行定时任务，只有一个线程占用线程池资源，另外如果要外部判断线程池的状态，则需要再启一个线程去定时轮询