多线程编程：Java并发工具库（如ConcurrentHashMap）的应用示例？

原创系统管理员 2024-09-16 06:04 70阅读 0赞

在Java中，我们经常使用`ConcurrentHashMap`来处理多线程环境下的数据共享问题。以下是一个简单的应用示例：

1. 创建一个同步的哈希映射。

```java
import java.util.concurrent.ConcurrentHashMap;

ConcurrentHashMap<String, String> sharedMap = new ConcurrentHashMap<>();
```

2. 在多线程场景下，如一个生产者线程和多个消费者线程，你需要使用`putIfAbsent`方法来保证数据的一致性。

```java
// 生产者线程
public class ProducerThread extends Thread {
    @Override
    public void run() {
        String key = "item1";
        String value = "This is item 1";

// 使用 putIfAbsent 来避免并发问题
        if (!sharedMap.putIfAbsent(key, value))) {
            System.out.println("Value for key 'item1' already exists.");
        }
    }
}

// 消费者线程
public class ConsumerThread extends Thread {
    @Override
    public void run() {
        String key = "item1";
        // 从共享哈希映射中获取值
        String value = sharedMap.get(key);

if (value != null) {
            System.out.println("Value for key 'item1' is: " + value);
        } else {
            System.out.println("Key 'item1' not found in the shared map.");
        }
    }
}

// 启动线程
public class Main {
    public static void main(String[] args) {
        // 创建生产者线程
        ProducerThread producer = new ProducerThread();
        producer.start();

// 创建消费者线程，数量可以根据需要增加
        for (int i = 0; i < 3; i++) {
            ConsumerThread consumer = new ConsumerThread();
            consumer.start();
        }

// 等待所有线程完成
        while (!producer.isFinished() || !consumer.isFinished())) {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
```

这个示例中，我们创建了一个生产者线程和三个消费者线程。生产者线程向共享哈希映射（ConcurrentHashMap）添加键值对。消费者线程从映射中获取键对应的值。

这样设计的多线程系统可以保证在并发环境下数据的一致性。