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

Question

我正在创建用户线程并将它们放入大小=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");

Answer 1

试试这个方法:

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

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