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<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();//擷取阻塞執行線程

    }

}