java使用的是Callable接口，可以获取线程的返回值。

class Task implements Callable{

        privateString filename;publicTask(String filename) {

            this.filename =filename;

        }

    @Override

      public String call() throwsException {try{

        Thread.sleep(1000);

        }catch(InterruptedException e) {

        e.printStackTrace();

        }

System.out.println("完成 "+filename);return"返回值" +filename;

}

}/*** 创建一个线程池，将50个任务分配进去，并发量最大为5

* 运行结束后，输出每个线程返回的结束

* title:ThreadPoolExecutorTest

* descript:

*@authorliuzh

* @date 2016年5月18日 下午8:16:26*/publicclassThreadPoolExecutorTest {publicvoidstart()throwsInterruptedException, ExecutionException {/*** 创建线程池，并发量最大为5

* LinkedBlockingDeque，表示执行任务或者放入队列*/ThreadPoolExecutor tpe=newThreadPoolExecutor(5, 10, 0,

TimeUnit.SECONDS,newLinkedBlockingDeque(),newThreadPoolExecutor.CallerRunsPolicy());//存储线程的返回值List> results =newLinkedList>();for(inti = 0; i < 10; i++) {

Task task=newTask(String.valueOf(i));

System.out.println("放入线程池：" +i);//调用submit可以获得线程的返回值Future result =tpe.submit(task);

results.add(result);

}//此函数表示不再接收新任务，//如果不调用，awaitTermination将一直阻塞tpe.shutdown();//1天，模拟永远等待System.out.println(tpe.awaitTermination(1, TimeUnit.DAYS));//输出结果for(inti = 0; i < 10; i++) {

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

}

}publicstaticvoidmain(String[] args)throwsInterruptedException, ExecutionException {

ThreadPoolExecutorTest test=newThreadPoolExecutorTest();

test.start();

}

}

输出样例：

放入线程池：0

放入线程池：1

放入线程池：2

放入线程池：3

放入线程池：4

放入线程池：5

放入线程池：6

放入线程池：7

放入线程池：8

放入线程池：9

完成 1

完成 0

完成 2

完成 3

完成 4

完成 9

完成 6

完成 8

完成 5

完成 7

true

返回值0

返回值1

返回值2

返回值3

返回值4

返回值5

返回值6

返回值7

返回值8

返回值9

原文链接：https://www.cnblogs.com/liu-zh/p/5506492.html