Java并发工具类：Apache Commons的运用实例

原创绝地灬酷狼 2024-12-05 20:33 15阅读 0赞

Apache Commons是Apache软件基金会提供的一套开源库，其中包含了许多用于处理并发和多线程问题的工具类。下面我们将通过几个具体的实例来展示如何在Java中使用Apache Commons的并发工具类。

1. **Semaphore（信号量）**：用于限制同时访问资源的数量。例如：

```java
import org.apache.commons.lang3.concurrent.Semaphore;

public class SemaphoreExample {
    private final Semaphore semaphore = new Semaphore(2);

public void accessResource() throws InterruptedException {
        semaphore.acquire(); // 确保有2个许可证可用
        System.out.println("访问资源中 ...");
        semaphore.release(); // 释放一个许可证
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        Thread thread1 = new Thread(example::accessResource, "线程1"));
        Thread thread2 = new Thread(example::accessResource, "线程2"));

thread1.start();
        thread2.start();

// 等待所有线程完成
        thread1.join();
        thread2.join();
    }
}
```

在上述示例中，我们使用Semaphore来限制同时访问资源的数量。当只有一个许可证可用时，`acquire()`方法将阻塞，直到有许可证可用。

2. **CountDownLatch（倒计时）**：用于协调多个线程的执行。当一个或多个线程完成它们的任务后，可以调用`countDown()`方法来减少倒计数。

示例：

```java
import org.apache.commons.lang3.concurrent.CountDownLatch;

public class CountDownLatchExample {
    private final CountDownLatch countDownLatch = new CountDownLatch(2);

public void doTask() throws InterruptedException {
        System.out.println("开始任务 ...");
        countDownLatch.countDown(); // 减少倒计数，表示任务完成
        System.out.println("任务完成 ...");
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample();
        Thread thread1 = new Thread(example::doTask, "线程1"));
        Thread thread2 = new Thread(example::doTask, "线程2"));

thread1.start();
        thread2.start();

// 等待所有线程完成
        thread1.join();
        thread2.join();
    }
}
```

上述示例展示了如何使用Apache Commons的CountDownLatch来协调多个线程的执行。当所有任务完成后，`countDown()`方法会被调用，从而减少倒计数。