启动包含 1000 个任务的池(其中最多 4 个任务应该能够并行执行)并在它们(单独)花费超过 3 秒时自动超时的最佳实践方法是什么?
虽然我发现 ExecutorService
似乎很有帮助(请参阅下面另一篇文章中的 SSCE),但我不知道如何使其适用于并行运行的多个任务(如 future.get(3, TimeUnit.SECONDS)
与启动任务的线程在同一线程上执行,因此没有机会并行启动多个任务):
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
public class Test {
public static void main(String[] args) throws Exception {
ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(new Task());
try {
System.out.println("Started..");
System.out.println(future.get(3, TimeUnit.SECONDS));
System.out.println("Finished!");
} catch (TimeoutException e) {
future.cancel(true);
System.out.println("Terminated!");
}
executor.shutdownNow();
}
}
class Task implements Callable<String> {
@Override
public String call() throws Exception {
Thread.sleep(4000); // Just to demo a long running task of 4 seconds.
return "Ready!";
}
}
谢谢!
最佳答案
如果您必须监视每个任务以在超过超时期限时终止它,则可以
- 任务本身必须跟踪时间并适当退出,或者
- 您必须为每个任务创建一个第二个看门狗线程。看门狗线程设置一个计时器并 hibernate ,在超时间隔到期后唤醒,然后终止任务(如果任务仍在运行)。
关于Java并行多个任务超时,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37399574/