线程池同步、异步调用Callable，Future

涉及内容

案例分析，用Future获取线程池执行结果

原理分析：Future实现原理

使用Future来获取线程池执行

代码

package com.myd.cn.ThreadLocal;	import java.util.ArrayList;	import java.util.List;	import java.util.Random;	import java.util.concurrent.Callable;	import java.util.concurrent.ExecutorService;	import java.util.concurrent.Executors;	import java.util.concurrent.Future;	public class ThreadPoolCallableTest {			public static void  testGetTicketsInfo() throws Exception{				 //根据CPU核数来创建线程数量，CPU密集型是N+1,I/O密集型是2N+1				 ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());				 //获取10家酒店的可预订房间				 int taskNum = 10;				 //主线程启动时间				 long mainStartTime = System.currentTimeMillis();				 //使用Future来获取覆写Callable的call方法的任务返回结果				 List
     
      
       >  futureList = new ArrayList<>();				 //1.提交Callable任务到线程池，执行该任务并返回结果				 for (int i = 0; i < taskNum; i++) {					 //使用重写Callable call方法来向线程池提交任务,并指定call方法返回值类型为String					 Callable
       
         callable = () ->{						 //每个Callable任务提交的开始时间 						 long start = System.currentTimeMillis();						  //随机指定睡眠时间来模拟从酒店获取可订房间数量的等待时间						 long sleep = new Random().nextInt(5000);						 return "Hotel-corps-result "+sleep;					 };					//使用submit提交任务,从submit获取返回值，返回值类型为call方法的返回值了类型String					 Future
        
          future = executorService.submit(callable);					 //将每个线程执行任务的Future，用于后续解析个线程结果					 futureList.add(future);				}				 //3.根据各任务执行后的返回的Future来解析返回结果				 for (Future
         
           future : futureList) {					String availableRoomsOfPerHotel = future.get();					System.out.println("执行获取的每个酒店的可用房任务后，返回每个酒店可用房间结果： "+availableRoomsOfPerHotel+" 间数");				}				 System.out.println(Thread.currentThread().getName()+" cost "+ (System.currentTimeMillis()-mainStartTime));			}			public static void main(String[] args) throws Exception {				testGetTicketsInfo();			}	}

执行流程
- 1.Callable任务是Runnable子类，执行任务是调用的是重写后的call方法。
- 2.执行完毕后返回Future，实际返回结果是在其子类FutureTask中。因为AbstractExecutorService会调用newTaskFor(task)方法，创建FutureTask,同时会把callable传入其中
- 3.FutureTask实现Runnalbe接口和继承Future，会执行重写run()方法，run()方法会执行提交到线程池callable的call方法（已被用户根据业务重写），然后返回结果(返回值设置到outCome中)
- 执行图示