如何使用ExecutorService在多线程中正确地向ConcurrentHashMap添加元素

ExecutorService executorService = Executors.newFixedThreadPool(10);

ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>();

class AddElementTask implements Runnable {
    private ConcurrentHashMap<String, String> map;
    private String key;
    private String value;

    public AddElementTask(ConcurrentHashMap<String, String> map, String key, String value) {
        this.map = map;
        this.key = key;
        this.value = value;
    }

    @Override
    public void run() {
        map.putIfAbsent(key, value);
    }
}

executorService.submit(new AddElementTask(map, "key1", "value1"));
executorService.submit(new AddElementTask(map, "key2", "value2"));
// 可以提交更多的任务

executorService.shutdown();
try {
    executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
} catch (InterruptedException e) {
    // 处理异常
}