理解和解决Java中的并发控制工具（如CyclicBarrier）案例

原创﹏ヽ暗。殇╰゛Y 2024-09-16 06:03 76阅读 0赞

Java中的并发控制工具，如CyclicBarrier，主要用于多线程环境下协调各线程的执行。以下是一个使用CyclicBarrier的例子：

```java
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    private final CyclicBarrier barrier = new CyclicBarrier(2, new Runnable() {
        @Override
        public void run() {
            System.out.println("Thread " + Thread.currentThread().getName() + " reached barrier and proceeded.");
        }
    })));

public static void main(String[] args) {
        new CyclicBarrierExample().start();
    }

private void start() {
        Thread t1 = new Thread(() -> {
            try {
                barrier.await();
            } catch (Exception e) {
                System.out.println("Error in thread 1: " + e.getMessage());
            }
            System.out.println("Thread 1 reached barrier and proceeded.");
        }));

Thread t2 = new Thread(() -> {
            try {
                barrier.await();
            } catch (Exception e) {
                System.out.println("Error in thread 2: " + e.getMessage());
            }
            System.out.println("Thread 2 reached barrier and proceeded.");
        }));

t1.start();
        t2.start();
    }
}
```

在这个例子中，我们创建了两个线程t1和t2。每个线程都会调用屏障的await方法来等待其他线程也达到屏障。

当所有线程都到达屏障时，屏障会释放所有等待的线程。然后各线程继续执行其后续代码。