gpt4 book ai didi

java - Executors.newFixedThreadPool 中各个线程的超时

转载 作者:太空宇宙 更新时间:2023-11-04 07:07:44 27 4
gpt4 key购买 nike

我正在创建用户线程并将它们放入大小=5 的固定池中。我希望我的线程在 5 分钟内执行。这些线程在远程服务器上完成了一些数据库操作。但由于网络延迟,某些线程只是停止并等待远程服务器的响应,因此它会导致我不希望的延迟。所以我希望所有待处理的线程在 5 分钟内完成,否则它们应该在特定超时时被终止或中断。我怎样才能实现这一目标。

我使用的是Jdk.1.6.0_45

        int i = 0;
ExecutorService executor = Executors.newFixedThreadPool(5);
while (i < 10) {
ThreadClass thread = new ThreadClass();
thread.setCounter(i);
executor.execute(thread);
i++;
}
executor.shutdown();
System.out.println("Wiating for threads to terminate");

while (!executor.isTerminated()) {}

System.out.println("Finished all threads");

最佳答案

试试这个方法:

executor.shutdown();
if (!executor.awaitTermination(5, TimeUnit.MINUTES)) {
executor.shutdownNow();
}

仅当您的线程在某些测试中断的函数上阻塞时,这才有效。否则你就无能为力:除了中断之外,没有办法可靠地停止线程。

关于java - Executors.newFixedThreadPool 中各个线程的超时,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21086379/

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com