Java多线程之~~~Callable接口获得返回值

ThreadPoolExecutor提供了另一个非常强有力的接口，那就是callable。这个接口和runnable类似，但是实现这个

接口的方法是call方法，这个方法是可以返回值的，弥补了runnable不能返回值的悲哀。而且这个方法可以配合ThreadP

oolExecutor使用，获得Future接口，从这个接口的名字我们就能知道，返回的这个类似于指向这个线程的一个指针，我

们能通过这个Future接口知道当前线程的运行情况，包括是否已经完成任务，目前运行情况，运行完成后的返回值等，

而且每个任务创建后直接通过ThreadPoolExecutor的submit方法提供，有一种非常自动化的感觉。爱不释手，简直停不

下来。下面我们就以计算多个数字的阶层为例子演示一下这个接口的使用方法。

package com.bird.concursey.charpet6;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class FactorialCalculator implements Callable<Integer> {
	
	private int number;
	
	public FactorialCalculator(int number) {
		super();
		this.number = number;
	}

	@Override
	public Integer call() throws Exception {
		int result = 1;
		if(number == 0 || number == 1) {
			result = 1;
		}else{
			for(int i = 2; i <= number; i++) {
				result *= i;
				TimeUnit.MILLISECONDS.sleep(20);
			}
		}
		System.out.printf("%s: %d\n",Thread.currentThread().
				getName(),result);
		return result;
	}
	
	public static void main(String[] args) {
		ThreadPoolExecutor execute = (ThreadPoolExecutor) Executors.newFixedThreadPool(3);
		List<Future<Integer>> results = new ArrayList<Future<Integer>>();
		Random random = new Random();
		for(int i = 0; i < 10; i++) {
			int number = random.nextInt(20);
			FactorialCalculator calcu = new FactorialCalculator(number);
			Future<Integer> result = execute.submit(calcu);
			results.add(result);
		}
		
		do{
			System.out.printf("Main: Number of Completed Tasks:%d\n",execute.getCompletedTaskCount());
			for (int i=0; i<results.size(); i++) {
				Future<Integer> result=results.get(i);
				System.out.printf("Main: Task %d: %s\n",i,result.isDone());
			}
			try {
				TimeUnit.MILLISECONDS.sleep(50);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}while(execute.getCompletedTaskCount() < results.size());
		
		System.out.printf("Main: Results\n");
		for(Future<Integer> fus : results) {
			try {
				System.out.printf("Main: Task %d: %d\n",1,fus.get());
			} catch (InterruptedException e) {
				e.printStackTrace();
			} catch (ExecutionException e) {
				e.printStackTrace();
			}
		}
		
		execute.shutdown();
	}

}

记住使用完成后，一定记得shutdown，这个方法，如果不调用这个方法，execute就会一直等待运行，即使没有线程

正在运行了，shundown并不是立刻关闭所有的线程，他只是表名，当他控制的其他线程完成后，execute会自动关闭

而已。