23 | Future：如何用多线程实现最优的“烧水泡茶”程序？

建议并发编程课程中的Demo代码，尽量少使用System.out.println, 因为其实现有使用隐式锁，一些情况还会有锁粗化产生

``` java ExecutorService futuresPool = Executors.newFixedThreadPool(3); Future<Price> future1 = futuresPool.submit(this::getPriceByS1); Future<Price> future2 = futuresPool.submit(this::getPriceByS2); Future<Price> future3 = futuresPool.submit(this::getPriceByS3); ExecutorService saveThreadPool = Executors.newFixedThreadPool(3); saveThreadPool.execute(() -> { try { Price r1= future1.get(); save(r1); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } }); saveThreadPool.execute(() -> { try { Price r2= future2.get(); save(r2); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } }); saveThreadPool.execute(() -> { try { Price r3= future3.get(); save(r3); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } }); ``` 用三个线程把这个并行执行，麻烦老师看看，谢谢

我不知道是不是理解错老师意思了，先分析依赖有向图，可以看到三条线，没有入度>1的节点 那么启动三个线程即可。 图： s1询价 -> s1保存 s2询价 -> s2保存 s3询价 -> s3保存 代码： new Thread(() -> { r1 = getPriceByS1(); save(r1); }).start(); new Thread(() -> { r2 = getPriceByS2(); save(r2); }).start(); new Thread(() -> { r3 = getPriceByS3(); save(r3); }).start(); 我觉得这里不需要future,除非询价和保存之间还有别的计算工作

老师，我看了下futruerask的源码，当调用futrue.get()方法，其实最终会调用unsafe方法是当前线程阻塞。但是我不太理解线程阻塞到哪去了，也没看到锁。

老师，你所说的订蛋糕，我这样理解对吗，把任务提交给线程池就是让蛋糕店做蛋糕；去看电影就是主线程做其他事，提货单是对应调用future的get

老师，jdk 8提供的CompletableFuture，以后异步处理是不是可以直接用此替代

课后习题，老师帮忙看下哦 public class ExecutorExample { private static final ExecutorService executor; static {executor = new ThreadPoolExecutor(4, 8, 1, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(1000), runnable -> null, (r, executor) -> {//根据业务降级策略}); } static class S1Task implements Callable<String> { @Override public String call() throws Exception {return getPriceByS1();}} static class S2Task implements Callable<String> { @Overridepublic String call() throws Exception {return getPriceByS2();}} static class S3Task implements Callable<String> {@Override public String call() throws Exception {return getPriceByS3();}} static class SaveTask implements Callable<Boolean> {private List<FutureTask<String>> futureTasks; public SaveTask(List<FutureTask<String>> futureTasks) {this.futureTasks = futureTasks; } @Override public Boolean call() throws Exception { for (FutureTask<String> futureTask : futureTasks) { String data = futureTask.get(10, TimeUnit.SECONDS); saveData(data); } return Boolean.TRUE; } } private static String getPriceByS1() { return "fromDb1"; } private static String getPriceByS2() { return "fromDb2"; } private static String getPriceByS3() { return "fromDb3"; } private static void saveData(String data) { //save data to db } public static void main(String[] args) { S1Task s1Task = new S1Task();FutureTask<String> st1 = new FutureTask<>(s1Task);S2Task s2Task = new S2Task();FutureTask<String> st2 = new FutureTask<>(s2Task);S3Task s3Task = new S3Task();FutureTask<String> st3 = new FutureTask<>(s3Task);List<FutureTask<String>> futureTasks = Lists.<FutureTask<String>>newArrayList(st1, st2, st3);FutureTask<Boolean> saveTask = new FutureTask<>(new SaveTask(futureTasks));executor.submit(st1);executor.submit(st2);executor.submit(st3);executor.submit(saveTask);}}

现在是在主线程串行完成3个询价的任务，执行第一个任务，其它2个任务只能等待执行，如果要提高效率，这个地方需要改进，可以用老师今天讲的futuretask，三个询价任务改成futuretask并行执行，效率会提高

老师，有问题问一下：1.在泡茶的例子中，如果使用线程池创建线程，假设有很多个泡茶任务都要反复调用线程池中的线程，那么在T2提前完成任务，T1获取T2的结果前，T2这个线程会不会被线程池回收？2.假设T1在T2前完成，当T1要获取T2结果时，T1中的代码是阻塞的状态吗？

我也同意张天屹同学的观点 这个询价操作如果之间没有联系的话 直接起三个线程就可以了 老师能不能讲一下 用线程池怎么就有关联了？