0
点赞
收藏
分享

微信扫一扫

JUC(8)Stream流式计算


文章目录

  • ​​1、ForkJoin​​

1、ForkJoin

ForkJoin 在JDK1.7 ,并执行任务!提高效率,大数据量
大数据:Map Reduce (把大任务拆分为小任务)

ForkJoin特点:工作窃取
这个里面维护的是双端队列

JUC(8)Stream流式计算_大数据量

JUC(8)Stream流式计算_大数据量_02


例子、异步调用线程

package com.completablecuture;


import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;

/**
* 异步调用:CompletableFuture
* 异步执行
* 成功回调
* 失败回调
*/
public class CompletableFutureDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
//发起一个请求
CompletableFuture<Void> completableFuture = CompletableFuture.runAsync(()->{

try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}

System.out.println(Thread.currentThread().getName()+"===>runAsync==>Void");
});
System.out.println("hello world!");
completableFuture.get();//获取阻塞执行线程

}

}

测试结果:

JUC(8)Stream流式计算_异步调用_03


举报

相关推荐

0 条评论