callable接口

Callable接口類似于Runnable接口，它的實例對象也可能被一個線程執行。

區別于Runnable接口，Callable接口的實現類可以返回結果，并且能夠拋出異常。

線程使用Callable

public class CallableTest {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        MyClass myClass = new MyClass();
        //FutureTask類是Runnable接口的一個實現類
        FutureTask<Integer> futureTask = new FutureTask<>(myClass);
        //兩個線程執行
        new Thread(futureTask).start();
        new Thread(futureTask).start();
        
        //這里會阻塞 等待線程任務即call方法執行完成
        //所以這一句一般放在需要取值的地方
        Integer result = futureTask.get();
        System.out.println(result);
    }
}

class MyClass implements Callable<Integer>{

    @Override
    public Integer call() throws Exception {
        System.out.println("call");
        TimeUnit.SECONDS.sleep(5);
        return 12345;
    }
}

上面代碼執行結果

call
12345

分析

Thread類的構造方法只接受Runnable接口的實例對象。Callable接口的對象不能直接傳給Thread類使用。

這樣看來Thread類和Callable接口不能直接關聯起來，只能通過間接的方式關聯。

FutureTask類實現了RunnableFuture接口

public class FutureTask<V> implements RunnableFuture<V>

RunnableFuture接口繼承了Runnable接口

public interface RunnableFuture<V> extends Runnable, Future<V> 

FutureTask類有一個構造方法可以傳一個Callable接口的實例

public FutureTask(Callable<V> callable) {
    if (callable == null)
        throw new NullPointerException();
    this.callable = callable;
    this.state = NEW;       // ensure visibility of callable
}

FutureTask對象可以傳給Thread類的構造方法，這樣Thread類和Callable接口就關聯起來了。

MyClass myClass = new MyClass();
//FutureTask類是Runnable接口的一個實現類
FutureTask<Integer> futureTask = new FutureTask<>(myClass);
new Thread(futureTask).start();

futureTask.get() 這個語句會等待線程任務執行完成，并且會緩存結果，所以上面兩條線程只輸出了一次call。

這是一個適配器模式