1.需求：
代码实现
2.analysis
并发编程分析思路：
分工，同步，互斥。
先分析同步：
烧水和洗茶具是同步的，所以分为两个任务。一个任务烧水，一个任务洗茶具。
优化分析：将一个任务做为主任务
一种最优的分工方案可以是下图所示的这样：用两个线程 T1 和 T2 来完成烧水泡茶程序，T1 负责洗水壶、烧开水、泡茶这三道工序，T2 负责洗茶壶、洗茶杯、拿茶叶三道工序，其中 T1 在执行泡茶这道工序时需要等待 T2 完成拿茶叶的工序。对于 T1 的这个等待动作，你应该可以想出很多种办法，例如 Thread.join()、CountDownLatch，甚至阻塞队列都可以解决，不过今天我们用 Future 特性来实现。
3.code
ShaoShuiMain
···
packagecn.pl.future.shaoshuiTest;
importjava.util.concurrent.ExecutionException;
importjava.util.concurrent.FutureTask;
importcn.pl.future.shaoshuiTest.childThread.ShaoShui;
importcn.pl.future.shaoshuiTest.childThread.XiTools;
publicclassShaoShuiMain{
publicstaticvoidmain(String[]args)throwsInterruptedException,ExecutionException{
//任务2 洗工具
FutureTask<String>f2=newFutureTask<>(newXiTools());
//任务1 烧水
FutureTask<String>f1=newFutureTask<>(newShaoShui(f2));
Threadt1=newThread(f1);
Threadt2=newThread(f2);
t1.start();
t2.start();
//等待上茶
System.out.println(f1.get());
}
}
···
ShaoShui
···
packagecn.pl.future.shaoshuiTest.childThread;
importjava.util.concurrent.Callable;
importjava.util.concurrent.FutureTask;
importjava.util.concurrent.TimeUnit;
publicclassShaoShuiimplementsCallable<String>{
FutureTask<String>f2;
publicShaoShui(FutureTask<String>f2) {
// TODO Auto-generated constructor stub
this.f2=f2;
}
@Override
publicStringcall()throwsException{
// TODO Auto-generated method stub
System.out.println("T1: 洗水壶...");
TimeUnit.SECONDS.sleep(1);
System.out.println("T1: 烧开水...");
// 获取 T2 线程的茶叶
Stringtf=f2.get();
TimeUnit.SECONDS.sleep(15);
System.out.println("T1: 拿到茶叶:"+tf);
System.out.println("T1: 泡茶...");
return" 上茶:"+tf;
}
}
···
XiTools
packagecn.pl.future.shaoshuiTest.childThread;
importjava.util.concurrent.Callable;
importjava.util.concurrent.TimeUnit;
publicclassXiToolsimplementsCallable<String>{
@Override
publicStringcall()throwsException{
// TODO Auto-generated method stub
System.out.println("T2: 洗茶壶...");
TimeUnit.SECONDS.sleep(1);
System.out.println("T2: 洗茶杯...");
TimeUnit.SECONDS.sleep(2);
System.out.println("T2: 拿茶叶...");
TimeUnit.SECONDS.sleep(1);
return" 龙井 ";
}
}
运行结果：
