import java.util.concurrent.*; public class FutureCook { public static void main(String[] args) throws InterruptedException, ExecutionException { long startTime = System.currentTimeMillis(); // 第一步 网购厨具 /*Callable<Chuju> onlineShopping = new Callable<Chuju>() { public Chuju call() throws Exception { System.out.println("第一步：下单"); System.out.println("第一步：等待送货"); Thread.sleep(10000); // 模拟送货时间 System.out.println("第一步：快递送到"); return new Chuju(); } }; FutureTask<Chuju> task = new FutureTask<Chuju>(onlineShopping); new Thread(task).start(); // 第二步 去超市购买食材 Thread.sleep(2000); // 模拟购买食材时间 Shicai shicai = new Shicai(); System.out.println("第二步：食材到位"); // 第三步 用厨具烹饪食材 if (!task.isDone()) { // 联系快递员，询问是否到货 System.out.println("第三步：厨具还没到，心情好就等着（心情不好就调用cancel方法取消订单）"); } Chuju chuju = task.get(); System.out.println("第三步：厨具到位，开始展现厨艺"); cook(chuju, shicai); System.out.println("总共用时" + (System.currentTimeMillis() - startTime) + "ms");*/ } // 用厨具烹饪食材 static void cook(Chuju chuju, Shicai shicai) {} // 厨具类 static class Chuju {} // 食材类 static class Shicai {} }
以上就是一个小例子，直接拷贝运行
另外我们还可以用以下代码实现多线程：通过lamda表达式
ExecutorService executor = Executors.newCachedThreadPool();
Future<Chuju> future = executor.submit(() -> { //Lambda 是一个 callable， 提交后便立即执行，这里返回的是 FutureTask 实例 System.out.println("running task");
Thread.sleep(10000); return new Chuju; });
if(!future.isDone()){
System.out.println("再等等厨具还没到");
future.get();
}
executor.shutdown();
