線程入門——從任務中產生返回值

import java.util.concurrent.Callable;

/**
 * Created by Administrator on 2017/9/1.
 */
public class TaskWithResult implements Callable<String> {
    private int id;

    public TaskWithResult(int id) {
        this.id = id;
    }

    @Override
    public String call() {
        return "result of TaskWithResult" + id;
    }

}

 

import java.util.ArrayList;
import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
 * Created by Administrator on 2017/9/1.
 */
public class CallableDemo {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();
        ArrayList<Future<String>> results = new ArrayList<Future<String>>();
        for (int i = 0; i < 10; i++) {
            results.add(executorService.submit(new TaskWithResult(i)));
        }
        for (Future<String> fs : results) {
            try {
                System.out.println(fs.get());
            } catch (InterruptedException e) {
                e.printStackTrace();
                return;
            } catch (ExecutionException e) {
                e.printStackTrace();
                return;
            } finally {
                executorService.shutdown();
            }
        }

    }
}

 

運行結果：

 

結論：Runnable是執行工做的獨立任務，可是它不返回任何值。若是你但願任務在完成時可以返回一個值，那麼能夠實現Callable接口而不是Runnable接口。在JAVA SE5中引入的Callabele接口而不是Runnable接口。

Callablel是一種具備類型參數的泛型，它的類型參數表示的是從方法call()（而不是run()）中返回的值，而且必須使用ExecutorServiceSubmit()方法調用它。submit()方法會產生Future對象，它用Callable返回結果的特定類型進行了參數化。能夠用isDone()方法來查詢Future是否已經完成。當任務完成時，它具備一個結果，你能夠調用get()方法來獲取該結果。也能夠不用isDone()進行檢查就直接調用get()，在這種狀況下，get()將阻塞，直至結果準備就緒。