在这种情况下,我们对能够中断超过预定义超时的任务的 ExecutorService 实现感兴趣。
其中一个实现是TimeoutThreadPoolExecutor,提供了为提交的任务指定超时时长的机制。
<br>import java.util.List;<br>导入 java.util.concurrent.*;<p>公共类TimeoutThreadPoolExecutor extends ThreadPoolExecutor {</p><pre class="brush:php;toolbar:false">private final long timeout; private final TimeUnit timeoutUnit; // ... (rest of the implementation)
}
要使用此执行器服务,只需创建一个实例,指定所需的timeout:
TimeoutThreadPoolExecutor executor = new TimeoutThreadPoolExecutor(..., timeout, TimeUnit.MILLISECONDS);
然后,照常将你的任务提交给执行者。超过指定超时的任务将被中断。
或者,您可以使用 ScheduledExecutorService:
ScheduledExecutorService executor = Executors.newScheduledThreadPool(2); Future<?> handler = executor.submit(new Callable() { /* ... */ }); executor.schedule(() -> handler.cancel(true), 10000, TimeUnit.MILLISECONDS);
此策略确保任务在之后中断10 秒。
以上是如何创建超时后中断任务的ExecutorService?的详细内容。更多信息请关注PHP中文网其他相关文章!