广州网站建设c2c,共享农业网站建设,长沙网页设计学校,使用html制作网页CyclicBarrier使用案例 /*** CyclicBarrier使用案例,线程执行任务完成后会停留在await(),* 直到所有线程执行任务完毕,才会被放行;* 接着就会继续执行其他的任务*/
public class CyclicBarrierExample {public static void main(String[] args) {int numThreads 3;CyclicBarri… CyclicBarrier使用案例 /*** CyclicBarrier使用案例,线程执行任务完成后会停留在await(),* 直到所有线程执行任务完毕,才会被放行;* 接着就会继续执行其他的任务*/
public class CyclicBarrierExample {public static void main(String[] args) {int numThreads 3;CyclicBarrier barrier new CyclicBarrier(numThreads, () - {System.out.println(All threads have reached the barrier. Starting the next phase.);});for (int i 0; i numThreads; i) {Thread worker new Thread(new Worker(barrier, Worker- i));worker.start();}}static class Worker implements Runnable {private CyclicBarrier barrier;private String workerName;public Worker(CyclicBarrier barrier, String workerName) {this.barrier barrier;this.workerName workerName;}Overridepublic void run() {System.out.println(LocalDateTime.now().format(DateTimeFormatter.ofPattern(hh:mm:ss)) Worker workerName is working);try {Thread.sleep((long) (Math.random() * 2000)); // 模拟不同的工作时间System.out.println(LocalDateTime.now().format(DateTimeFormatter.ofPattern(hh:mm:ss)) Worker workerName has reached the barrier);barrier.await(); // 等待所有线程到达屏障System.out.println(LocalDateTime.now().format(DateTimeFormatter.ofPattern(hh:mm:ss)) Worker workerName is continuing to work);} catch (InterruptedException | BrokenBarrierException e) {e.printStackTrace();}}}
}输出结果
12:45:40 Worker Worker-1 is working
12:45:40 Worker Worker-2 is working
12:45:40 Worker Worker-0 is working
12:45:40 Worker Worker-0 has reached the barrier
12:45:40 Worker Worker-1 has reached the barrier
12:45:42 Worker Worker-2 has reached the barrier
All threads have reached the barrier. Starting the next phase.
12:45:42 Worker Worker-2 is continuing to work
12:45:42 Worker Worker-0 is continuing to work
12:45:42 Worker Worker-1 is continuing to workProcess finished with exit code 0
