Java-CyclicBarrier的簡單樣例
阿新 • • 發佈:2017-06-30
rri popu exceptio dex cut bit content -a sub
內容:一個主任務等待兩個子任務,通過CyclicBarrier的await()實現。此Runnable任務在CyclicBarrier的數目達到後,全部其他線程被喚醒前被運行。
public class CyclicBarrierTest { class MainTask implements Runnable { @Override public void run() { System.out.println(">>>>主任務開始運行!<<<<"); } } class SubTask implements Runnable { private String name; private CyclicBarrier cyclicBarrier; SubTask(String name, CyclicBarrier cyclicBarrier) { this.name = name; this.cyclicBarrier = cyclicBarrier; } @Override public void run() { System.out.println("[子任務" + name + "]開始運行了!"); for (int i = 0; i < 999999; i++) ; System.out.println("[子任務" + name + "]運行完畢了,並通知障礙器已經完畢了"); try { cyclicBarrier.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } } } public static void main(String[] args) { CyclicBarrierTest test = new CyclicBarrierTest(); CyclicBarrier cyclicBarrier = new CyclicBarrier(2, test.new MainTask()); SubTask A = test.new SubTask("A", cyclicBarrier); SubTask B = test.new SubTask("B", cyclicBarrier); ExecutorService executor = Executors.newCachedThreadPool(); executor.execute(A); executor.execute(B); } }
Java-CyclicBarrier的簡單樣例