future, TimeoutException和带finally块的Callables

Question

如果Callable通过future被取消，线程中的finally块会被调用吗?get(超时,TimeUnit.SECONDS) ?

class MyCallable implements Callable<Future<?>>{
    public Future<?> call(){
        Connection conn = pool.getConnection();
        try {
            ... 
        } catch(CatchExceptions ce){
        } finally {
            conn.close();
        }
    } 
}
... 
future.get(executionTimeoutSeconds, TimeUnit.SECONDS);

我知道最后总是会被调用，但我猜我错过了一些关于线程如何被中断的东西。这是我运行的一个测试，没有显示我的最后块被解雇。

@Test
public void testFuture(){
    ExecutorService pool =  Executors.newFixedThreadPool(1);
    try {
        pool.submit(new TestCallable()).get(1, TimeUnit.SECONDS);
    } catch (InterruptedException e) {
        e.printStackTrace();
    } catch (ExecutionException e) {
        e.printStackTrace();
    } catch (TimeoutException e) {
        e.printStackTrace();
    }
}
class TestCallable implements Callable<Void> {
    @Override
    public Void call() throws Exception {
        try{
        while(true){
            Thread.sleep(3000);
            break;
        }
        } catch (Exception e){
            System.out.println("EXCEPTION CAUGHT!");
            throw e;
        } finally {
            System.out.println("FINALLY BLOCK RAN!");
        }
    }
}

看起来如果我添加了awaitTermination，它就会运行。这个测试通过了…

public void testFuture(){
    ExecutorService pool =  Executors.newFixedThreadPool(1);
    try {
        pool.submit(new TestCallable()).get(1, TimeUnit.SECONDS);
    } catch (InterruptedException e) {
        e.printStackTrace();
    } catch (ExecutionException e) {
        e.printStackTrace();
    } catch (TimeoutException e) {
        e.printStackTrace();
    }
    try {
        pool.awaitTermination(10, TimeUnit.SECONDS);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

Answer 1

future.get(...)不取消线程。它只等待线程完成，如果等待超时则抛出TimeoutException。

future.cancel(true) 将导致线程中断。这可能会也可能不会阻止线程的处理。这取决于try ...部分内部发生了什么。例如，当线程被中断时，Thread.sleep(...)、Object.wait(...)和其他方法抛出InterruptedException。否则，您需要使用

检查线程中断标志。

if (Thread.currentThread().isInterrupted()) {
    // maybe stop the thread or whatever you want
    return;
}

如果进入try块，finally块总是被调用(无论是否中断)，除非出现某种JVM故障和崩溃。我怀疑你的线程没有被中断，所以只是继续运行。