JUC（8）Stream流式计算

JUC（8）Stream流式计算

文章目录

​​1、ForkJoin​​

1、ForkJoin

ForkJoin 在JDK1.7 ，并执行任务！提高效率，大数据量 大数据：Map Reduce (把大任务拆分为小任务）

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

例子、异步调用线程

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 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();//获取阻塞执行线程 }}

测试结果：

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。