JUC(8)Stream流式计算
  TEZNKK3IfmPf 2023年11月12日 23 0

1、ForkJoin

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

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

JUC(8)Stream流式计算

JUC(8)Stream流式计算


例子、异步调用线程

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流式计算


【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

  1. 分享:
最后一次编辑于 2023年11月12日 0

暂无评论

推荐阅读
  TEZNKK3IfmPf   23天前   50   0   0 java
  TEZNKK3IfmPf   2024年05月31日   55   0   0 java
TEZNKK3IfmPf