如果需要更多时间，则终止 threadexecutor 中的任务

Question

场景如下：

我有一个 java 主进程，它使用 JMS 发布到某个 ActiveMQ 代理。

每次应该将消息发送到代理时，都会使用固定大小的线程池（使用 ThreadExecutor）中的一个线程，并在其中进行发布调用。

现在，发布调用是阻塞调用，如果代理关闭，线程本身将继续等待。

我想创建一个线程池，这样如果特定线程在 X 时间内没有完成任务，它只会返回，即如果代理已关闭且发布未完成，则线程不会继续等待，而是返回到游泳池。

目前还没有办法使这个发布调用异步，所以我猜处理这种情况的唯一方法就是上面提到的方法。

如果线程无法在给定的时间范围内完成任务，是否有任何 ThreadExecutor 允许我立即终止线程？

希望有人提供更优雅的解决方案。

Answer 1

ExecutorService 接口提供带有 timeout 参数的 invokeAll() 和 invokeAny() 方法。

例子：

ExecutorService executor = Executors..newFixedThreadPool(2);
executor.invokeAll(Arrays.asList(new Callable<Void>(){

    @Override
    public Void call() throws Exception {
        try {
            // do your task
        } catch (InterruptedException e) {
            // your task was forced to end
        }
        return null;
    }

}), 5, TimeUnit.SECONDS);
executor.shutdown();