成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

Fork-Join框架

?xiaoxiao, / 881人閱讀

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

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

優(yōu)點：就是充分利用線程進行并行計算，減少線程間的競爭。缺點是還是存在競爭比如在隊列中只有一個任務時，同時也消耗了更多的系統(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;

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

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

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

            // 合并子任務
            sum = leftResult + rightResult;
        }
        return sum;
    }

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

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

        //執(zhí)行一個任務
        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://systransis.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í)行完畢并不會馬上死亡，而是在池中準備為下一個請求提供服務。 多線程并發(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ù)。在行中，對每個小任務得到的結(jié)果進行匯總。 為了保證的可讀性，本文采用意譯而非直譯。 想閱讀更多優(yōu)質(zhì)文章請猛戳GitHub博客,一年百來篇優(yōu)質(zhì)文章等著你！ 從ES6 開始，我們大都使用的是 P...

    vspiders 評論0 收藏0

發(fā)表評論

0條評論

?xiaoxiao,

男|高級講師

TA的文章

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