cyclicbarrier

    4熱度

    1回答

    我有一個需要由三方(線程,可以說)填充的列表。我正在使用循環屏障來實現此功能。一切工作正常,但我無法使用結果列表,而不會導致強迫睡眠。下面是代碼: public class Test{ List<Integer> item = new Vector<Integer>(); public void returnTheList(){ CyclicBarrier cb = new C

    1熱度

    1回答

    這是我正在嘗試做的。我有一些線程應該在一個共同的點上等待,然後才能繼續,所以顯而易見的解決方案是使用CyclicBarrier。但是我也想計算線程執行的總時間。我在類ConcurrentExecutionActionTimer中定義了以下實用方法。 public static long elapsedTimeUsingCyclicBarrier(Executor executor, int con

    1熱度

    3回答

    我想將一些商業案例映射到循環壁壘的使用。假設我們有促銷優惠,只有3位客戶可以獲得促銷優惠。其餘的不會得到報價。 要映射這個場景,我已經使用了循環屏障。儘管代碼正在運行,但我不確定如何處理這種情況,即部分客戶無法獲得此優惠。現在,我嘗試使用帶有超時值的await()API,以便我可以捕獲TimeoutException並讓客戶知道他無法使用促銷優惠。這導致BarrierBrokenException

    2熱度

    1回答

    我正在學習如何在java中使用countdownLatch,並且我在代碼中創建了一個如下所示的簡單示例。 我對這種機制的理解是,它只是一種強制只有一個線程等待其他線程等待其他線程完成工作,然後那個線程正在等待的時候,當另一個線程開始工作時(s)完成。 我的問題是,如果我有4個線程't1,t2,t3和t4',它們應該按照所述的順序開始,並且每個線程應該在前導/前導結束時開始。換句話說,t2應等待t1

    1熱度

    5回答

    我實施巴恩斯小屋算法爲N體問題的一個多線程溶液線程的數目。 Main類執行以下操作 public void runSimulation() { for(int i = 0; i < numWorkers; i++) { new Thread(new Worker(i, this, gnumBodies, numSteps)).start(); }

    1熱度

    2回答

    我傾向於CyclicBarrier,我寫了這個演示。 import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; import static java.util.concurrent.ThreadLocalRandom.current; public class

    -2熱度

    2回答

    我學習了關於ciclycbarrier,並試圖創建一個小應用程序。我的應用程序的構造是如下: public FileDownloader(String line, int maxDownload){ this.position = 0; this.line = line; this.maxDownload = maxDownload; this.urls =

    1熱度

    2回答

    我試圖用CyclicBarrier重新實現我的併發代碼,這對我來說是新的。我可以沒有,但我的時間試用這對我的其他的解決方案,這個問題我已經是用下面的代碼死鎖情況: //instance variables (fully initialised elsewhere). private final ExecutorService exec = Executors.newFixedThreadPool

    -1熱度

    1回答

    是否有辦法終止等待循環屏障完成的所有線程。 在我的情況下,我有3個線程,如果在A點見面,那麼只能進行,否則該過程應該被殺死。我已經使用循環屏障來檢查是否所有三個線程都在A點會議,如果是的話繼續,但如果即使1個線程失敗,那麼我怎麼能殺死所有線程使用此屏障。 Thet線程正在等待。我不想讓他們現在等待。

    0熱度

    2回答

    所以我寫了這個程序來運行這個機器人類的多個線程使用cyclicbarrier來同步線程。由於我對循環屏障的理解很少,我認爲它會自動同步我的線程,但似乎沒有。基於我的進度整數值,我的機器人線程需要做什麼才能同步? public class Robot implements Runnable{ public static final int on = 0x0001; public static f