线程池 submit 方法结合 Callable Future 的使用

在工作中，将许多个任务交给线程池运作时，我们可能还会有以下需求：

1、需要取消某个任务的运行

2、需要接收任务运行的结果

3、需要在一个任务出错时候，停止未运行任务的运行（通过抛出异常，捕获异常则可以继续运行）

那么我们会用到线程池的 submit 方法，我们的任务需要实现Callable接口，任务的返回值和其取消操作被封装在Future（FutureTask实现）内部

举例：

import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.*;
public class CallableTest {

	public static void main(String[] args) throws Exception {
		ExecutorService executorService = Executors.newCachedThreadPool();
		List<Future> resultList = new ArrayList<Future>();

		// 创建10个任务并执行
		for (int i = 0; i < 10; i++) {
			// 使用ExecutorService执行Callable类型的任务，并将结果保存在future变量中
			// 最终会实例化一个FutureTask对象，其run方法会调用Callable的call方法，并且支持cancel等操作
			Future future = executorService.submit(new TaskWithResult(i));

			resultList.add(future);// 将任务执行结果存储到List中
		}
		executorService.shutdown();

		// 遍历任务的结果，未执行完会阻塞
		for (Future fs : resultList) {
			// 打印各个线程（任务）执行的结果
			System.out.println(fs.isDone() + "=" + fs.get() + "=" + fs.isDone());
		}
	}
}

class TaskWithResult implements Callable {

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

	@Override
	public String call() throws Exception {
		System.out.println("call()方法被调用！" + Thread.currentThread().getName());

		boolean flag = new Random().nextBoolean();
		if (flag) {
			System.out.println("异常撞击！");
			throw new TaskException("Meet error in task." + Thread.currentThread().getName());
		}

		Thread.sleep(2000);

		return "结果是：" + id;
	}
}

class TaskException extends Exception {

	TaskException(String message) {
		super(message);
	}
}