亚洲中字慕日产2020,大陆极品少妇内射AAAAAA,无码av大香线蕉伊人久久,久久精品国产亚洲av麻豆网站

資訊專欄INFORMATION COLUMN

Fork-Join框架

?xiaoxiao, / 930人閱讀

摘要：為了減少竊取線程和別竊取線程之間的競爭我們通常使用雙端隊列。被竊取線程永遠從雙端隊列的頭部獲取任務(wù)，竊取線程永遠從雙端隊列的尾部獲取內(nèi)容。優(yōu)點就是充分利用線程進行并行計算，減少線程間的競爭。使用操作的線程不能執(zhí)行操作。

Fork-Join框架 
Fork和Join是java 1.7提供的用于定型執(zhí)行的框架，將大任務(wù)切分成若干個小任務(wù)執(zhí)行，小任務(wù)執(zhí)行結(jié)果匯總成大任務(wù)的框架。從字面上理解就是Fork把大任務(wù)切分成若干個小任務(wù)Join就是把小任務(wù)合并得到大任務(wù)結(jié)果。使用工作竊取算法。
工作竊取算法
從其他線程里獲取工作任務(wù)得一種算法。使用工作竊取算法可以方便我們將大任務(wù)切分成多個小任務(wù)。為了減少線程間的競爭，我們?yōu)槊總€任務(wù)分別放入不同的隊列里，線程和隊列一一對應(yīng)，但是有些線程會先把任務(wù)做完，這些做完了自己任務(wù)的線程就去幫助其他線程進行任務(wù)，這是他們會訪問同一個隊列。為了減少竊取線程和別竊取線程之間的競爭我們通常使用雙端隊列。被竊取線程永遠從雙端隊列的頭部獲取任務(wù)，竊取線程永遠從雙端隊列的尾部獲取內(nèi)容。

優(yōu)點：就是充分利用線程進行并行計算，減少線程間的競爭。缺點是還是存在競爭比如在隊列中只有一個任務(wù)時，同時也消耗了更多的系統(tǒng)資源創(chuàng)建更多的線程。

局限：

在使用Fork/Join只能使用Fork和Join進行同步操作，如果在使用了其他機制時工作線程就不能進行其他操作了。比如在Fork/Join框架中使用了失眠，那么在睡眠過程中就不能執(zhí)行其他操作了。

使用Fork/Join操作的線程不能執(zhí)行io操作。

不能拋出檢查異常，必須使用必要的代碼來檢查他們。

演示代碼

@Slf4j
public class ForkJoinTaskExample extends RecursiveTask {

    public static final int threshold = 2;
    private int start;
    private int end;

    public ForkJoinTaskExample(int start, int end) {
        this.start = start;
        this.end = end;
    }

    @Override
    protected Integer compute() {
        int sum = 0;

        //如果任務(wù)足夠小就計算任務(wù)
        boolean canCompute = (end - start) <= threshold;
        if (canCompute) {
            for (int i = start; i <= end; i++) {
                sum += i;
            }
        } else {
            // 如果任務(wù)大于閾值，就分裂成兩個子任務(wù)計算
            int middle = (start + end) / 2;
            ForkJoinTaskExample leftTask = new ForkJoinTaskExample(start, middle);
            ForkJoinTaskExample rightTask = new ForkJoinTaskExample(middle + 1, end);

            // 執(zhí)行子任務(wù)
            leftTask.fork();
            rightTask.fork();

            // 等待任務(wù)執(zhí)行結(jié)束合并其結(jié)果
            int leftResult = leftTask.join();
            int rightResult = rightTask.join();

            // 合并子任務(wù)
            sum = leftResult + rightResult;
        }
        return sum;
    }

    public static void main(String[] args) {
        ForkJoinPool forkjoinPool = new ForkJoinPool();

        //生成一個計算任務(wù)，計算1+2+3+4
        ForkJoinTaskExample task = new ForkJoinTaskExample(1, 100);

        //執(zhí)行一個任務(wù)
        Future result = forkjoinPool.submit(task);

        try {
            log.info("result:{}", result.get());
        } catch (Exception e) {
            log.error("exception", e);
        }
    }
}

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://www.ezyhdfw.cn/yun/77708.html

相關(guān)文章

  • Java 8 的 JVM 有多快？Fork-Join 性能基準測試

    摘要：這減輕了手動重復執(zhí)行相同基準測試的痛苦，并簡化了獲取結(jié)果的流程。處理項目的代碼并從標有注釋的方法處生成基準測試程序。用和運行該基準測試得到以下結(jié)果。同時，和的基線測試結(jié)果也有略微的不同。 Java 8 已經(jīng)發(fā)布一段時間了，許多開發(fā)者已經(jīng)開始使用 Java 8。本文也將討論最新發(fā)布在 JDK 中的并發(fā)功能更新。事實上，JDK 中已經(jīng)有多處java.util.concurrent 改動，但...

    Euphoria 評論0 收藏0

  • Java多線程之線程安全與異步執(zhí)行

    摘要：同步包裝器任何集合類使用同步包裝器都會變成線程安全的，會將集合的方法使用鎖加以保護，保證線程的安全訪問。線程池中的線程執(zhí)行完畢并不會馬上死亡，而是在池中準備為下一個請求提供服務(wù)。 多線程并發(fā)修改一個數(shù)據(jù)結(jié)構(gòu)，很容易破壞這個數(shù)據(jù)結(jié)構(gòu)，如散列表。鎖能夠保護共享數(shù)據(jù)結(jié)構(gòu)，但選擇線程安全的實現(xiàn)更好更容易，如阻塞隊列就是線程安全的集合。 線程安全的集合 Vector和HashTable類提供了線...

    taoszu 評論0 收藏0

  • 史上最全的并發(fā)編程學習

    一：線程基礎(chǔ)知識 1.并發(fā)編程的基本概念 2. 線程的基本操作 3.線程之間的通信wait和notify 4.join和yield以及sleep詳解 5. synchronized關(guān)鍵字講解 6. volatile原理 7. 線程組 8.線程優(yōu)先級 9.守護線程 10.ThreadLocal 二：JDK并發(fā)包 1.jdk并發(fā)工具類 重入鎖 信號量 讀寫鎖 CountDownLatch cyclic...

    qylost 評論0 收藏0

  • Promise 中的三兄弟 .all(), .race(), .allSettled()

    摘要：對于的來說基元函數(shù)包括組合函數(shù)的類型簽名返回情況完成如果傳入的可迭代對象為空，會同步地返回一個已完成狀態(tài)的。相反，如果是在指定的時間之后完成，剛返回結(jié)果就是一個拒絕狀態(tài)的從而觸發(fā)方法指定的回調(diào)函數(shù)。在行中，對每個小任務(wù)得到的結(jié)果進行匯總。 為了保證的可讀性，本文采用意譯而非直譯。 想閱讀更多優(yōu)質(zhì)文章請猛戳GitHub博客,一年百來篇優(yōu)質(zhì)文章等著你！ 從ES6 開始，我們大都使用的是 P...

    vspiders 評論0 收藏0

發(fā)表評論

0條評論

最新活動
閱讀需要支付1元查看
<