callable接口

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

區(qū)別于Runnable接口，Callable接口的實(shí)現(xiàn)類可以返回結(jié)果，并且能夠拋出異常。

線程使用Callable

public class CallableTest {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        MyClass myClass = new MyClass();
        //FutureTask類是Runnable接口的一個實(shí)現(xiàn)類
        FutureTask<Integer> futureTask = new FutureTask<>(myClass);
        //兩個線程執(zhí)行
        new Thread(futureTask).start();
        new Thread(futureTask).start();
        
        //這里會阻塞 等待線程任務(wù)即call方法執(zhí)行完成
        //所以這一句一般放在需要取值的地方
        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;
    }
}

上面代碼執(zhí)行結(jié)果

call
12345

分析

Thread類的構(gòu)造方法只接受Runnable接口的實(shí)例對象。Callable接口的對象不能直接傳給Thread類使用。

這樣看來Thread類和Callable接口不能直接關(guān)聯(lián)起來，只能通過間接的方式關(guān)聯(lián)。

FutureTask類實(shí)現(xiàn)了RunnableFuture接口

public class FutureTask<V> implements RunnableFuture<V>

RunnableFuture接口繼承了Runnable接口

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

FutureTask類有一個構(gòu)造方法可以傳一個Callable接口的實(shí)例

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

FutureTask對象可以傳給Thread類的構(gòu)造方法，這樣Thread類和Callable接口就關(guān)聯(lián)起來了。

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

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

這是一個適配器模式