Java中并发工具库（Concurrent Collections）应用示例

原创落日映苍穹つ 2024-09-13 02:57 69阅读 0赞

在Java中，`ConcurrentCollections`是Java集合框架的一部分，它提供了一些线程安全的并发容器。以下是一些常见工具库的应用示例：

1. `Semaphore`: 信号量是一个同步原语，可以限制同时访问某个资源的线程数量。例如：

```java
Semaphore限量 = new Semaphore(3); // 允许的最大线程数

// 线程A需要访问资源
new Thread(() -> {
    try {
       限量.acquire(); // 请求使用资源
        // 访问资源代码
       限量.release(); // 释放资源，允许其他线程使用
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

// 线程B需要访问资源
new Thread(() -> {
    try {
       限量.acquire(); // 请求使用资源
        // 访问资源代码
       限量.release(); // 释放资源，允许其他线程使用
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

// 线程C需要访问资源
new Thread(() -> {
    try {
       限量.acquire(); // 请求使用资源
        // 访问资源代码
       限量.release(); // 释放资源，允许其他线程使用
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();
```

2. `BlockingQueue`: 静态阻塞队列是一个可以被多个消费者(线程)同时访问的缓冲队列。例如：

```java
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

BlockingQueue<String> queue = new LinkedBlockingQueue<>(10); // 初始化容量为10

// 生产者线程
new Thread(() -> {
    while (true) { // 永远循环
        String item = "Item " + (queue.size() + 1)); // 创建要添加的元素
        if (!queue.offer(item)) { // 如果不能立即添加到队列，将阻塞直到队列空间可用
            System.out.println("Queue is full, item: " + item);
            break;
        }
    }
}).start();

// 消费者线程
new Thread(() -> {
    while (true) {
        try {
            String item = queue.take(); // 从队列中取出一个元素，如果为空阻塞直到有元素可用
            System.out.println("Consumed item: " + item);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}).start();
```

以上示例展示了`Semaphore`用于控制访问资源的线程数量和`BlockingQueue`作为生产者和消费者之间共享数据的缓冲队列。