在给定的超时后,Future.get(timeout)不能可靠地引发TimeoutException。这是正常的行为还是我可以做些什么使它更可靠?该测试在我的机器上失败。但是,如果我睡3000而不是2000,它将通过。

public class FutureTimeoutTest {
@Test
public void test() throws
    ExecutionException,
    InterruptedException {

    ExecutorService exec = Executors.newSingleThreadExecutor();
    final Callable call = new Callable() {
        @Override
        public Object call() throws Exception {
             try {
                Thread.sleep(2000);
            } catch (InterruptedException ex) {
                ex.printStackTrace();
            }
            return 0;
        }
    };
    final Future future = exec.submit(call);
    try {
        future.get(1000, TimeUnit.MILLISECONDS);
        fail("expected TimeoutException");
    } catch (TimeoutException ignore) {
    }
}

}

最佳答案

没有理由期望测试通过。假定您将任务提交执行后等待完成,那么在等待Future#get()之前,可能要经过任何时间,这使任务有足够的时间来耗尽 sleep 时间并完成任务。

在您的情况下,我们可以假定在Executor中运行的线程处于焦点,而在test()中运行的主线程处于保留状态,尽管处于可运行状态。至于观察到的将提交的任务暂停两秒和三秒之间的差异,我希望您会发现甚至三秒都不足够的情况,这取决于计算机上其他正在忙的事情。

关于java - 为什么Java Future.get(timeout)不可靠?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/4350941/

10-11 19:26