Java多線程與並發庫高級應用-Callable與Future的應用

Callable這種任務可以返回結果，返回的結果可以由Future去拿

>Future取得的結果類型和Callable返回的結果類型必須一致，這是通過泛型來實現的。

 

package com.java.juc;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
/**
 * 1.創建執行線程的方式三：實現Callable 接口。相較與實現Runnable的方式有返回值。
 * 2.執行Callable 方式，需要FutureTask 實現類的支持，用於接收運算結果。
 * @author Administrator
 *
 */
public class TestCallableFuture {

    public static void main(String[] args) {

        CallableDemo callableDemo = new CallableDemo();
        
        //執行Callable 方式，需要FutureTask 實現類的支持，用於接收運算結果。
        FutureTask<Integer> result = new FutureTask<>(callableDemo);
        new Thread(result).start();
        
        //接收線程運算后的結果
        try {
            Integer sum = result.get();  //FutureTask也可用於閉鎖，在線程運算的過程中，運算的結果是沒有打印的，result.get() 的操作是沒有運行的
            //這類似於閉鎖 CountDownLatch
            System.out.println(sum);
            System.out.println("------------------");
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }

}

class CallableDemo implements Callable<Integer>{

    @Override
    public Integer call() throws Exception {  //實現的call() 有返回值
        int sum = 0;
        for(int i = 0;i<1000000;i++){
            sum+=i;
        }
        return sum;
    }
    
}

 

 

>CompletionService用於提交一組Callable任務，其take方法返回已完成的一個Callable任務對應的Future對象。

　　好比我同時種了幾塊地的麥子，然后就等待收割。收割時，則是那塊先成熟了，則先去收割哪塊麥子。

Future<String> future = threadPool.submit(new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(2000); return "hello"; } }); System.out.println("等待結果"); try { System.out.println("拿到結果： "+future.get()); } catch (Exception e) { e.printStackTrace(); }

這種發方式是Future去主動詢問Callable有沒有產生結果

 

>CompletionService用於提交一組Callable任務，其take方法返回已完成的一個Callable任務對應的Future對象。

　　　　 ExecutorService executor = Executors.newFixedThreadPool(10); CompletionService<Integer> completionService = new ExecutorCompletionService<>(executor); for(int i = 0;i<10;i++){ final int seq = i; completionService.submit(new Callable<Integer>() { @Override public Integer call() throws Exception { Thread.sleep(new Random().nextInt(5000)); return seq; } }); } for(int i = 0;i<10;i++){ //等待獲取結果
            try { System.out.println(completionService.take().get()); } catch (Exception e) { e.printStackTrace(); }; }