异步编程还得看JDK8
话说，异步不看不知道，编程都说JDK7当时升级JDK8的异步时候，升级了非常多的编程内容，不得不说，异步这升级真的编程大。
什么是异步异步编程
在很多时候，我们在进程中使用单一线程从头到尾地执行程序，编程比如程序向另外一台服务器发出请求，异步由于网络等外部原因，编程此种通信任务往往会耗费大量时间，异步进程如果在此期间仅仅只能等待网络或网络上其他机器的编程响应，将严重地降低了性能。异步
如果程序调用某个方法，编程等待其执行全部处理后才能继续执行，异步我们称其为同步的。相反，在处理完成之前就返回调用方法则是异步的。
我们在编程语言的流程中添加了异步控制的部分，这部分的编程可以称之为异步编程。
JDK中的异步编程
FutureFuture模式在 JDK5 的时候就有, Future模式，云服务器只是发起了耗时操作，函数立马就返回了，真正执行具体操作由另外一个工作线程去完成，并不会阻塞客户端线程。所以在工作线程执行耗时操作的时候客户端无需等待，可以继续做其他事情，等到需要的时候再向工作线程获取结果。
举个最简单的例子，我们烧水的时候么，不用一直在炉子旁边看着，在烧水的过程中，我们需要做一些其他的事情，比如去写一会代码，但是在你去写代码之前，会给你一个假的结果，比如，我已经烧开了，但是，在你去写代码的时候，他就开始疯狂加火，等到水烧开为止，等到你口渴想倒水的服务器租用时候，发现水是已经烧开的，也就是说，当你在写代码之前的时候收到的是个假的结果。
实际上，Future 模式无法立即给出你想要的结果，但它会给你一个契约，之后你可以随时通过这个契约来获取你想要的结果。
异步模式主要是和同步模式进行对比的，我们画个图来看看。
黄色区域的位置的Y轴长度则表示的是你需要等待的所有时间，在这个时间内，你没有办法做任何的事情，只能在这里等着，但是异步的源码下载话，就完全不用这个样子了。
在JDK中Future模式有一套完整的实现。
我们来写案例代码实验一下：
没有是用 Future 的代码。
NormalThreadTestpublic class NormalThreadTest {
public static void main(String[] args) throws Exception {
long start = System.currentTimeMillis();
// 开启购买厨具线程
ShoppingThread shopping = new ShoppingThread();
shopping.start();
shopping.join(); // 保障厨具购买并送货
// 获取到购买厨具
KitchenWare kc = shopping.kc;
// 买食材
FoodMaterial fm = new FoodMaterial();
Thread.sleep(2000);
System.out.println("第二步: 食材已经到位");
// 烹饪美食
cooking(kc, fm);
System.out.println("第三步: 美食烹饪完成");
long end = System.currentTimeMillis();
System.out.println("烹饪美食时间为:" + (end - start));
}
/
*** 定义网上购物厨具线程
* @author Administrator
**/
static class ShoppingThread extends Thread {
// 厨具对象引用
private KitchenWare kc;
@Override
public void run() {
System.out.println("第一步: 网上下单");
System.out.println("第一步: 等待厨具");
try {
Thread.sleep(5000); // 等待厨具时间
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("第一步: 快递送货");
// 生产厨具
kc = new KitchenWare();
}
}
/
*** 厨具类
* @author Administrator
**/
static class KitchenWare {
}
/
*** 食材类
* @author Administrator
**/
static class FoodMaterial {
}
/
*** 定义烹饪食物的方法
* @param kc
* @param fm
*/
static void cooking(KitchenWare kc, FoodMaterial fm) {
}
}
运行结果：
第一步: 网上下单
第一步: 等待厨具
第一步: 快递送货
第二步: 食材已经到位
第三步: 美食烹饪完成
烹饪美食时间为:7043
已经使用Future的代码。
FutureThreadTestpublic class FutureThreadTest {
public static void main(String[] args) throws Exception {
long start = System.currentTimeMillis();
Callable
public KitchenWare call() throws Exception {
System.out.println("第一步: 网上下单");
System.out.println("第一步: 等待厨具");
try {
Thread.sleep(5000); // 等待厨具时间
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("第一步: 快递送货");
return new KitchenWare();
}
};
// 包装为异步执行的对象
FutureTask
new Thread(task).start();
// 买食材
FoodMaterial fm = new FoodMaterial();
Thread.sleep(2000);
System.out.println("第二步: 食材已经到位");
if (!task.isDone()) {
System.out.println("厨具还没有到.....");
}
// 通过阻塞形式获取到异步块执行的结果
KitchenWare kc = task.get(); // 阻塞
// 烹饪美食
cooking(kc, fm);
System.out.println("第三步: 美食烹饪完成");
long end = System.currentTimeMillis();
System.out.println("烹饪美食时间为:" + (end - start));
}
/
*** 厨具类
* @author Administrator
**/
static class KitchenWare {
}
/
*** 食材类
* @author Administrator
**/
static class FoodMaterial {
}
/
*** 定义烹饪食物的方法
* @param kc
* @param fm
*/
static void cooking(KitchenWare kc, FoodMaterial fm) {
}
}
执行结果：
第一步: 网上下单
第一步: 等待厨具
第二步: 食材已经到位
厨具还没有到.....
第一步: 快递送货
第三步: 美食烹饪完成
烹饪美食时间为:5027
这个是JDK5中就有的 Future 来实现 异步编程的，那么接下来我们看1.8的异步编程。
CompletableFutureFuture 虽然可以实现获取异步执行结果的需求，但是它没有提供通知的机制，我们无法得知Future什么时候完成，我们通过上面的代码也完全能看出来。
为什么在JDK5之后，又推出新的异步编程，因为使用 Future 要么使用阻塞，在 future.get() 的地方等待 Future 返回的结果，这时又变成同步操作。要么使用 isDone() 轮询地判断 Future 是否完成，这样会耗费CPU的资源。所以阿粉猜测所以在JDK8又推出了 CompletableFuture。
之前 Future 需要等待 isDone 为 true 才能知道任务跑完了。或者就是用 get 方法调用的时候会出现阻塞。而使用 CompletableFuture 的使用就可以用 then ， when 等等操作来防止以上的阻塞和轮询 isDone 的现象出现。
CompletableFuture 有四个方法来创建CompletableFuture对象。
public static CompletableFuture
public static CompletableFuture
public static CompletableFuturesupplyAsync(Suppliersupplier)
public static CompletableFuturesupplyAsync(Suppliersupplier, Executor executor)
Asynsc表示异步,而supplyAsync与runAsync不同在与前者异步返回一个结果,后者是void.第二个函数第二个参数表示是用我们自己创建的线程池,否则采用默认的ForkJoinPool.commonPool()作为它的线程池.其中Supplier是一个函数式接口,代表是一个生成者的意思,传入0个参数,返回一个结果。
我们写一个最简单的测试代码：
public static void test2() throws Exception {
//supplyAsync内部使用ForkJoinPool线程池执行任务
CompletableFuture
//模拟执行耗时任务
System.out.println("task doing...");
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
//返回结果
return "100";
}).whenComplete((v,r)->{
System.out.println("计算结果是: "+v);
});
//CompletableFuture里使用的线程池里的线程默认是daemon的。main线程结束后，整个程序也
//结束了，这里将main线程join后任务里的代码才可以执行完
Thread.currentThread().join();
}
而使用 CompletableFuture 能有效的避开使用 Futrue 出现的缺点。
看来，JDK 每一次的更新换代，不光是加了一些新的内容，而且像开发一样，每次迭代的时候，同时也会更新之前的一些不完美的内容，不是么?