Java并发工具库：Apache Commons Concurrent 的实战案例

原创水深无声 2024-09-29 21:15 161阅读 0赞

Apache Commons Concurrent是Apache Commons项目的一部分，它提供了一组强大的并发工具，如线程池、队列、锁等。

以下是一些实战案例：

1. 线程池示例：
```java
// 创建一个固定大小的线程池
ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池
executor.submit(() -> {
    System.out.println("Task 1 is running by thread: " + Thread.currentThread().getName());
    // 模拟耗时操作
    try {
        Thread.sleep(2000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}));

// 关闭线程池
executor.shutdown();

// 确保所有任务已完成
while (!executor.isTerminated()) {
    System.out.println("Task is still running ...");
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}
```
2. 队列示例：
```java
import java.util.concurrentLinkedBlockingQueue;

public class QueueExample {
    public static void main(String[] args) {
        // 创建一个无界阻塞队列
        LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>(10);

// 提交任务到队列
        for (int i = 0; i < 20; i++) {
            queue.put("Task " + i);
            System.out.println("Task " + i + " added to the queue.");
        }

// 从队列中取出元素并打印
        while (!queue.isEmpty()) {
            String task = queue.take();
            System.out.println("Task " + task + " removed from the queue.");
        }
    }
}
```
以上案例展示了Apache Commons Concurrent库的常用工具和功能，包括线程池、队列等。