java Fork/Join框架的使用方法

本篇內(nèi)容介紹了“java Fork/Join框架的使用方法”的有關(guān)知識(shí)，在實(shí)際案例的操作過程中，不少人都會(huì)遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

Fork/Join框架重點(diǎn)說明：

1，在必要的情況下，將一個(gè)大任務(wù)，進(jìn)行拆分（fork） 成若干個(gè)子任務(wù)（拆到不能再拆，這里就是指我們制定的拆分的臨界值），再將一個(gè)個(gè)小任務(wù)的結(jié)果進(jìn)行join匯總。

2，F(xiàn)ork/Join采用“工作竊取模式”。

3，F(xiàn)orkJoin更有效的利用的CPU資源。

4，Java 8 中將并行流進(jìn)行了優(yōu)化，Stream API可以聲明性的通過parallel()與sequential()在并行流與串行流中隨意切換。

以下是簡單示例：

public class ForkJoinWorkTest extends RecursiveTask<Long> {

    private Long start;
    private Long end;
    public static final Long critical = 100000L;

    public ForkJoinWorkTest(Long start, Long end) {
        this.start = start;
        this.end = end;
    }

    @Override
    protected Long compute() {

        Long length = end - start;
        if(length <= critical) {
            // 拆分完畢
            Long sum = 0L;
            for(Long i = start; i <= end; i++) {
                sum += i;
            }
            return sum;
        } else {
            // 未拆分完畢
            Long middle = (end + start)/2;
            ForkJoinWorkTest right = new ForkJoinWorkTest(start, middle);
            right.fork();
            ForkJoinWorkTest left = new ForkJoinWorkTest(middle + 1, end);
            left.fork();

            return right.join() + left.join();
        }

    }

}

單元測試代碼：

import java.util.concurrent.*;
import java.util.stream.LongStream;

public class ForkJoinWorkTestDemo {

    public static void main(String args[]) {

        Long startTime = System.currentTimeMillis();
        ForkJoinPool forkJoinPool = new ForkJoinPool();
        ForkJoinTask<Long> forkJoinTask = new ForkJoinWorkTest(0L,100000000L);
        Long invoke = forkJoinPool.invoke(forkJoinTask);
        Long endTime = System.currentTimeMillis();
        System.out.println("forkAndJoin:"+invoke+" time:"+(endTime - startTime));

        System.out.println("=======================================================");

        Long startTime1 = System.currentTimeMillis();
        Long sum = 0L;
        for(Long i=0L;i<=100000000L;i++) {
            sum += i;
        }
        Long endTime1 = System.currentTimeMillis();
        System.out.println("normalSum:"+sum+" time:"+(endTime1 - startTime1));

        System.out.println("=======================================================");

        Long startTime2 = System.currentTimeMillis();
        Long sum8 = LongStream.rangeClosed(0, 100000000L).parallel().reduce(0,Long::sum);
        Long endTime2 = System.currentTimeMillis();
        System.out.println("Jdk8Sum:"+sum8+" time:"+(endTime2 - startTime2));

    }

}

結(jié)果如下：

“java Fork/Join框架的使用方法”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！