package com.lan;import java.util.ArrayList;import java.util.List;import java.util.concurrent.BlockingQueue;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;import java.util.concurrent.LinkedBlockingQueue;import java.util.concurrent.RejectedExecutionException;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;public class CallTest {    static LinkedBlockingQueue<Runnable> quere = new LinkedBlockingQueue<Runnable>();//new ThreadPoolExecutor(nThreads, nThreads,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>());    static ExecutorService exec = new ThreadPoolExecutor(10,10,0,TimeUnit.SECONDS,quere);    static LinkedBlockingQueue<Callable> cquere = new LinkedBlockingQueue<Callable>();    public static void main(String[] args) throws InterruptedException, ExecutionException {        //        Callable<String> c ;        //        Future<String> c = exec.submit(new Test());        //        Object o = c.get();        //        System.out.println("o-- "+o);        Future[] f = new Future[10];        List<Future<String>> list = new ArrayList<Future<String>>(10);        List<Boolean> ff = new ArrayList<Boolean>(10);        Callable a = new Test(0);        for (int i = 0; i < 10; i++) {            System.out.println(" 加入一个 "+i);            Callable c = new Test(i);            list.add(exec.submit(c));            ff.add(false);        }        Boolean complete = false;        int j = 0;        while(!complete){            for (int i = 0; i < 10; i++) {                if(ff.get(i).equals(false) && list.get(i).isDone() ){                    j++;                    ff.set(i, true);                    System.out.println("--"+list.get(i).get());                }            }            if(j>=10){                complete = true;            }        }        System.out.println("out of while");        exec.shutdown();    }}class Test implements Callable<String>{    private int count;    public int getCount(){        return count;    };    public Test(int count){        this.count = count;    }    public String call() throws Exception {        //        Thread.sleep(5000L);        long start = System.currentTimeMillis();        while( (System.currentTimeMillis()-start)<1000L ){        }        return Thread.currentThread().getName()+"thread count: "+count;    }}

 加入一个 0 加入一个 1 加入一个 2 加入一个 3 加入一个 4 加入一个 5 加入一个 6 加入一个 7 加入一个 8 加入一个 9--pool-1-thread-1thread count: 0--pool-1-thread-2thread count: 1--pool-1-thread-3thread count: 2--pool-1-thread-5thread count: 4--pool-1-thread-7thread count: 6--pool-1-thread-9thread count: 8--pool-1-thread-4thread count: 3--pool-1-thread-6thread count: 5--pool-1-thread-8thread count: 7--pool-1-thread-10thread count: 9out of while

而FutureObject.get（）句柄在执行时，当前线程是会等待线程对象的执行完毕的，所以测试这里用了一个while。所以，如果要使用.get方法时，最好先判断一下isDone。