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

Question

这是场景:

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

每次要向代理发送消息时，都会使用固定大小的线程池(使用 ThreadExecutor)中的一个线程，并在其中进行发布调用。

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

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

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

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

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

Answer 1

ExecutorService接口(interface)提供带有 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();