Java并发控制工具如Lock和Semaphore的案例

原创你的名字 2024-09-22 05:03 62阅读 0赞

在Java中，`Lock`和`Semaphore`是两个常用的并发控制工具，分别用于线程级别的互斥和资源分享。

1. Lock（锁）：
   - `ReentrantLock`：支持公平、非公平两种策略。例如：
     ```java
     private final ReentrantLock lock = new ReentrantLock();

public void doSomething() {
         lock.lock(); // 获取锁
         try {
             // 执行任务
             System.out.println("Doing something...");
         } finally {
             // 无论是否异常，都必须释放锁
             lock.unlock();
         }
     }
     ```
   - `Synchronized`：使用Java的内置同步机制。例如：
     ```java
     private Object lockObj = new Object();

public void doSomething() {
         synchronized (lockObj) { // 使用对象作为锁
             System.out.println("Doing something...");
         }
     }
     ```

2. Semaphore（信号量）：
   - `CountDownLatch`：用于多个线程等待某个事件。例如：
     ```java
     private final CountDownLatch countDownLatch = new CountDownLatch(3); // 三个线程需要等待

public void doSomething() throws InterruptedException {
         System.out.println("Doing something...");
         // 等待信号量释放，表示其他线程已完成任务
         countDownLatch.await();
         System.out.println("Done!");
     }
     ```
   - `Semaphore`：直接用于控制多个共享资源的访问。例如：
     ```java
     private final Semaphore semaphore = new Semaphore(2); // 最多两个线程同时访问

public void doSomething() throws InterruptedException {
         System.out.println("Doing something...");
         // 信号量获取，表示需要一个许可证进入资源区域
         semaphore.acquire();
         try {
             // 现在可以操作资源了
             // ...
         } finally {
             // 无论是否成功访问资源，都必须释放信号量
             semaphore.release();
         }
         System.out.println("Done!");
     }
     ```

这些工具可以帮助Java开发者更好地控制并发行为，避免数据不一致或线程安全问题。