cyclicbarrier

2熱度

2回答

我想模擬使用CyclicBarrier的triatlon競爭，但它沒有按預期工作，我不知道爲什麼。比賽的每一部分都要等到所有的跑步者都完成了前一個跑步者，但看起來好像是在等待着。這是第一階段的一段代碼： class Runner implements Runnable { private CyclicBarrier bar = null; private static i

8熱度

1回答

何時重置Java多線程中的CyclicBarrier

我在閱讀CyclicBarrier在以下鏈接 http://java-latte.blogspot.in/2013/10/cyclicbarrier-in-java-concurrency.html。在示例1中，CyclicRaceDemo.java的主要方法，CyclicBarrier正在重新使用，而不調用復位方法。我跑了這個例子，它工作正常。所以，我想知道reset方法有什麼用處。什麼時候

0熱度

1回答

的CyclicBarrier勞克並行線程執行不同的邏輯

下面的代碼似乎不平行地運行，但在發出其他甚至要求在每個單獨的線程AWAIT（）方法後一個請求。有人可以幫助使這個線程並行調用。 public class XYZ { private static String baseUrl = "http://xyz.polls.com"; public static void main(String[] args) { Mul

3熱度

3回答

壁壘打破例如

我讀的書Java Concurrency in Practice的地方說， CyclicBarrier允許各方的固定數量屏障點反覆會合，並在分解的問題轉換成並行迭代算法有用固定數量的獨立子問題。有人可以舉例說明它如何將問題分解成多個獨立的子問題？

0熱度

1回答

循環屏障重用？

我目前想實現應用程序與機器溝通，並應主要工作如下：程序將消息發送到服務器（在這種情況下，第一個255個字節的文件）。機器以「成功接收消息」或「接收消息錯誤」響應作出響應。根據機器的響應，程序必須決定是否發送下一條消息（下一個255字節）或不是（最後一條消息的錯誤，必須重新開始）。等等程序需要發送的每條消息（取決於文件的大小）。所以，我們認爲有一個線程來做發送，另一個做接收，因爲我們有一

0熱度

2回答

實施的CyclicBarrier在Java中使用線程特定類型的線和信號燈

public class cyclicBarrier { private static int n; private static int count; private static semaphore mutex; private static semaphore turnstile; private static semaphore turns

0熱度

1回答

使用信號量在java中實現一個循環屏障

問題如下，因爲只有使用down（）調用屏障才能等待n個線程到達，然後在關鍵區域中一起執行所有n個線程現在我該如何通知barrier.down這個線程，它現在可以繼續。我嘗試加notifyAll（）後階段2（）並且不起作用。幫幫我？ :) public class cyclicBarrier { private int n; private int count; pri

1熱度

2回答

使用的CyclicBarrier

Java的循環線程我有這個一般結構的程序： init create CyclicBarrier initialise all threads, attaching to barrier *start all threads* wait for join display stats *start all threads* perform calculation await bar

3熱度

1回答

的ExecutorService與Runnable接口份額的CyclicBarrier

我有一個共享CyclicBarrier使用正運行的類在Java中的並行解決的問題，而Runnable由ExecutorService處理，這是代碼： public class Worker implements Runnable { private CyclicBarrier writeBarrier; private int index; private int v

1熱度

1回答

CyclicBarrier上的Visibilty同步？

當使用CyclicBarrier同步Java中的線程時，它們是否同步非易失性變量？ int a = 0; int b = 0; CyclicBarrier barrier = new CyclicBarrier(2); /*** Thread 1 ***/ public void run() { a = 2; barrier.await(); doSome