資訊專欄INFORMATION COLUMN
摘要：為了減少竊取線程和別竊取線程之間的競爭我們通常使用雙端隊列。被竊取線程永遠從雙端隊列的頭部獲取任務，竊取線程永遠從雙端隊列的尾部獲取內容。優點就是充分利用線程進行并行計算，減少線程間的競爭。使用操作的線程不能執行操作。
Fork-Join框架
Fork和Join是java 1.7提供的用于定型執行的框架，將大任務切分成若干個小任務執行，小任務執行結果匯總成大任務的框架。從字面上理解就是Fork把大任務切分成若干個小任務Join就是把小任務合并得到大任務結果。使用工作竊取算法。
從其他線程里獲取工作任務得一種算法。使用工作竊取算法可以方便我們將大任務切分成多個小任務。為了減少線程間的競爭，我們為每個任務分別放入不同的隊列里，線程和隊列一一對應，但是有些線程會先把任務做完，這些做完了自己任務的線程就去幫助其他線程進行任務，這是他們會訪問同一個隊列。為了減少竊取線程和別竊取線程之間的競爭我們通常使用雙端隊列。被竊取線程永遠從雙端隊列的頭部獲取任務，竊取線程永遠從雙端隊列的尾部獲取內容。
優點：就是充分利用線程進行并行計算，減少線程間的競爭。缺點是還是存在競爭比如在隊列中只有一個任務時，同時也消耗了更多的系統資源創建更多的線程。
局限：
在使用Fork/Join只能使用Fork和Join進行同步操作，如果在使用了其他機制時工作線程就不能進行其他操作了。比如在Fork/Join框架中使用了失眠，那么在睡眠過程中就不能執行其他操作了。
使用Fork/Join操作的線程不能執行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); // 執行子任務 leftTask.fork(); rightTask.fork(); // 等待任務執行結束合并其結果 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); //執行一個任務 Future result = forkjoinPool.submit(task); try { log.info("result:{}", result.get()); } catch (Exception e) { log.error("exception", e); } } }
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/77708.html
摘要：這減輕了手動重復執行相同基準測試的痛苦，并簡化了獲取結果的流程。處理項目的代碼并從標有注釋的方法處生成基準測試程序。用和運行該基準測試得到以下結果。同時，和的基線測試結果也有略微的不同。 Java 8 已經發布一段時間了，許多開發者已經開始使用 Java 8。本文也將討論最新發布在 JDK 中的并發功能更新。事實上，JDK 中已經有多處java.util.concurrent 改動，但...
摘要：同步包裝器任何集合類使用同步包裝器都會變成線程安全的，會將集合的方法使用鎖加以保護，保證線程的安全訪問。線程池中的線程執行完畢并不會馬上死亡，而是在池中準備為下一個請求提供服務。 多線程并發修改一個數據結構，很容易破壞這個數據結構，如散列表。鎖能夠保護共享數據結構，但選擇線程安全的實現更好更容易，如阻塞隊列就是線程安全的集合。 線程安全的集合 Vector和HashTable類提供了線...
一：線程基礎知識 1.并發編程的基本概念 2. 線程的基本操作 3.線程之間的通信wait和notify 4.join和yield以及sleep詳解 5. synchronized關鍵字講解 6. volatile原理 7. 線程組 8.線程優先級 9.守護線程 10.ThreadLocal 二：JDK并發包 1.jdk并發工具類 重入鎖 信號量 讀寫鎖 CountDownLatch cyclic...
摘要：對于的來說基元函數包括組合函數的類型簽名返回情況完成如果傳入的可迭代對象為空，會同步地返回一個已完成狀態的。相反，如果是在指定的時間之后完成，剛返回結果就是一個拒絕狀態的從而觸發方法指定的回調函數。在行中，對每個小任務得到的結果進行匯總。 為了保證的可讀性，本文采用意譯而非直譯。 想閱讀更多優質文章請猛戳GitHub博客,一年百來篇優質文章等著你！ 從ES6 開始，我們大都使用的是 P...
閱讀 3280·2021-11-24 09:38
閱讀 2154·2021-11-23 09:51
閱讀 1745·2021-10-13 09:39
閱讀 2620·2021-09-23 11:53
閱讀 1405·2021-09-02 15:40
閱讀 3656·2019-08-30 15:54
閱讀 1131·2019-08-30 13:04
閱讀 2563·2019-08-30 11:01
