如何使用FutureTask处理超时？

Question

我有一个令人沮丧的问题:我试图查看TimeoutException是否在下面的代码中抛出，但这永远不会发生。它总是打印当前时间5次，然后结束。

class MyTask1 implements Callable<Void> {  

    public Void call() throws Exception {  
        for (int i=0; i < 5; i++) {
            System.out.println(new java.util.Date());
            Thread.sleep(1000);
        }
        return null;
    }  
}

public class Timeout {
    public static void main(String[] args) throws Exception {
        FutureTask<Void> futureTask = new FutureTask<Void>(new MyTask1());
        futureTask.run();
        try {
            futureTask.get(1000, TimeUnit.MILLISECONDS); // Check if FutureTask completed in the given time
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        } catch (TimeoutException e) {
            futureTask.cancel(true);
            e.printStackTrace();
        }   
    }
}

我使用Thread.sleep(1000)，所以call()方法至少需要5秒(因为使用for循环做了5次)。并且我通过设置超时值1秒来调用get()方法。

但是它为什么不抛出TimeoutException呢？

这可能是How do I get FutureTask to return after TimeoutException?的副本

但如果有人能帮上忙，那就更好了，因为这真的很令人沮丧。或者我不知道如何使用FutureTask来处理超时？

Answer 1

您需要在单独的线程上运行FutureTask (例如，使用Executor)。您当前正在同一线程中运行它，因此直到run()完成后才会发生get()调用。

更新：

如果你在java中线程化方面需要帮助，在oracle文档中有一个很棒的tutorial。