Java并发工具类如Semaphore、CyclicBarrier的应用实例

原创冷不防 2024-10-20 10:06 30阅读 0赞

在Java中，`Semaphore`和`CyclicBarrier`是两个非常实用的并发工具类。

1. Semaphore（信号量）：
Semaphore是一种信号机制，它允许多个线程访问一个有限资源，但同时只能有一个线程访问该资源。

应用实例：
```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private Semaphore permit = new Semaphore(1);

public void acquirePermission() throws InterruptedException {
        permit.acquire();
        System.out.println("Thread " + Thread.currentThread().getName() + " has access to the resource.");
    }

public void releasePermission() {
        permit.release();
        System.out.println("Resource released by " + Thread.currentThread().getName()));
    }
    
    public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        
        // 创建两个线程
        Thread t1 = new Thread(() -> {
            try {
                example.acquirePermission();
                example.releasePermission();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread t2 = new Thread(() -> {
            try {
                example.acquirePermission();
                // 模拟线程执行耗时操作
                Thread.sleep(500);
                example.releasePermission();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

// 启动线程
        t1.start();
        t2.start();

}
}
```
在这个例子中，两个线程分别尝试获取资源（`acquirePermission()`）并执行操作。由于信号量的限制，只有一个线程能同时访问资源。

当线程执行耗时操作（模拟）后，它会释放资源（`releasePermission()`）以便其他线程可以使用该资源。