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

精选留言

• 
  aroll

  2019-04-20 17:59:54

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

  作者回复

  好建议

  2019-04-20 22:07:03

• 
  vector

  2019-04-21 23:37:15

  最近使用CompletableFuture工具方法以及lamda表达式比较多，语言语法的变化带来编码效率的提升真的很大。
• 
  undifined

  2019-04-20 08:42:10

  课后题：
  可以用 Future
  ExecutorService threadPoolExecutor = Executors.newFixedThreadPool(3);
  Future<R> future1 = threadPoolExecutor.submit(Test::getPriceByS1);
  Future<R> future2 = threadPoolExecutor.submit(Test::getPriceByS2);
  Future<R> future3 = threadPoolExecutor.submit(Test::getPriceByS3);
  R r1 = future1.get();
  R r2 = future2.get();
  R r3 = future3.get();
  
  也可以用 CompletableFuture
  CompletableFuture<R> completableFuture1 = CompletableFuture.supplyAsync(Test::getPriceByS1);
  CompletableFuture<R> completableFuture2 = CompletableFuture.supplyAsync(Test::getPriceByS2);
  CompletableFuture<R> completableFuture3 = CompletableFuture.supplyAsync(Test::getPriceByS3);
  CompletableFuture.allOf(completableFuture1, completableFuture2, completableFuture3)
  .thenAccept(System.out::println);
  老师这样理解对吗 谢谢老师
• 
  Asanwos

  2019-04-21 18:15:07

  不是不建议使用 Executors 创建线程池了吗？？？
  
• 
  Joker

  2019-11-06 18:37:59

  ``` 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();
  }
  });
  ```
  
  用三个线程把这个并行执行，麻烦老师看看，谢谢

  作者回复

  我觉得没问题。也可以用一个线程池，把查询和保存放一个线程里。

  2019-11-06 21:41:37

• 
  张天屹

  2019-04-20 07:50:51

  我不知道是不是理解错老师意思了，先分析依赖有向图，可以看到三条线，没有入度>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,除非询价和保存之间还有别的计算工作

  作者回复

  用线程池就用到了

  2019-04-20 13:22:57

• 
  魏斌斌

  2019-06-17 20:33:51

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

  作者回复

  可以看看操作系统原理有关线程，进程的那部分

  2019-06-22 07:51:34

• 
  三木禾

  2019-05-18 18:25:37

  这个可以用生产消费者模式啊
• 
  Sunqc

  2019-04-30 07:34:22

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

  作者回复

  理解的对
  

  2019-04-30 10:09:42

• 
  ヾ(◍°∇°◍)ﾉﾞ

  2019-04-30 23:20:21

  分别提交三个futuretask给线程池，然后最后分别get出结果，统一进行保存数据库
• 
  the only Mia’s

  2020-07-25 07:43:38

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

  作者回复

  可以

  2020-07-26 18:56:45

• 
  linqw

  2019-04-22 23:55:23

  课后习题，老师帮忙看下哦
  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);}}

  作者回复

  没问题，就是有点复杂，代码还可以精简一下
  

  2019-04-23 08:16:37

• 
  henry

  2019-04-20 08:29:44

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

  作者回复

  👍
  

  2019-04-20 13:21:56

• 
  见南山

  2020-04-27 21:00:01

  给最后问题再加一步，询价后，得到最小的一家。题就比较好了
• 
  女巫在寒江

  2020-04-06 16:03:59

  ExecutorService executor = Executors.newFixedThreadPool(3);
  
  executor.submit(new Task1());
  executor.submit(new Task2());
  executor.submit(new Task3());
  
  class Task1 implement Runnable {
  void run(){
  r = getPriceByS1();
  save(r);
  }
  }
  
  class Task2 implement Runnable {
  void run(){
  r = getPriceByS2();
  save(r);
  }
  }
  
  class Task3 implement Runnable {
  void run(){
  r = getPriceByS3();
  save(r);
  }
  }
• 
  稚者

  2019-11-01 11:07:47

  烧水泡茶的Demo有点小问题，Task2的启动时间应该在Task1的洗茶壶之后开始，现在的代码是一起开始。
• 
  圆圜

  2019-04-22 09:24:45

  你这个不对啊，应该是executeservice.submit t2furturetask，不能直接提交t2
• 
  张德

  2019-04-21 23:27:13

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

  作者回复

  如果每分钟询价1万次，还能直接创建线程吗？联系指的是线程池和future，不是三个查询操作
  

  2019-04-22 08:22:23

• 
  捞鱼的搬砖奇

  2019-04-21 01:44:29

  Future的get()是拿到任务的执行结果不吧。为什么又说是拿到方法的入参了。
• 
  QQ怪

  2019-04-20 12:41:39

  在实际项目中应用已经应用到了Feture,但没有使用线程池，没有那么优雅，所以算是get到了👍