CallableAndFuture

Callable和Runnable的区别如下：

I    Callable定义的方法是call，而Runnable定义的方法是run。

II   Callable的call方法可以有返回值，而Runnable的run方法不能有返回值。

III  Callable的call方法可抛出异常，而Runnable的run方法不能抛出异常。

Future 介绍

Future表示异步计算的结果，它提供了检查计算是否完成的方法，以等待计算的完成，并检索计算的结果。Future的cancel方法可以取消任务的执行，它有一布尔参数，参数为 true 表示立即中断任务的执行，参数为 false 表示允许正在运行的任务运行完成。Future的 get 方法等待计算完成，获取计算结果。

import java.util.concurrent.Callable;

import java.util.concurrent.CompletionService;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.ExecutorCompletionService;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

public class CallableAndFuture {

    public static void main(String[] args) {

        ExecutorService threadPool = Executors.newCachedThreadPool();

        CompletionService<Integer> cs = new ExecutorCompletionService<Integer>(threadPool);

        for(int i = 1; i < 5; i++) {

            final int taskID = i;

            cs.submit(new Callable<Integer>() {

                public Integer call() throws Exception {

                    return taskID;

                }

            });

        }

        for(int i = 1; i < 5; i++) {

            try {

                System.out.println(cs.take().get());

            } catch (InterruptedException e) {

                e.printStackTrace();

            } catch (ExecutionException e) {

                e.printStackTrace();

            }

        }

    }

}       

其实也可以不使用CompletionService，可以先创建一个装Future类型的集合，用Executor提交的任务返回值添加到集合中，最后遍历集合取出数据

import java.util.ArrayList;

import java.util.concurrent.Callable;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.Future;

public class CallableAndFuture {

    public static void main(String[] args) {

        //用future实现

        ExecutorService threadPool = Executors.newCachedThreadPool();

        ArrayList<Future<Integer>> results = new ArrayList<Future<Integer>>();

        for(int i = 1; i < 5; i++) {

            final int taskID = i;

            results.add(threadPool.submit(new Callable<Integer>() {

                public Integer call() throws Exception {

                    return taskID;

                }

            }));

        }

        for(int i = 1; i < 5; i++) {

            try {

                System.out.println(results.get(i-1).get());

            } catch (InterruptedException e) {

                e.printStackTrace();

            } catch (ExecutionException e) {

                e.printStackTrace();

            }

        }

    }

}