使用 ConcurrentHashMap 和同步块(synchronized block)实现 Java 并发

Question

这是我的主类，它初始化并启动 5 个不同的线程:

public class Server implements Runnable {
    Server1 server1;
    Thread server1Thread;

    public Server() {}

    @Override
    public void run() {
        server1 = new Server1();
        server1Thread = new Thread(server1);
        server1Thread.start();
    }

    public static void main(String[] args) {
        for (int i = 0; i < 5; i++) {
            Server s = new Server();
            s.run();
        }
    }
}

这是我的Server1可运行:

import java.util.concurrent.ConcurrentHashMap;
public class Server1 implements Runnable {
    private ConcurrentHashMap<Integer, Integer> storage= new ConcurrentHashMap<>();

    public Server1() {}

    @Override
    public void run() {
        synchronized (this){
            for (int i = 0; i < 10; i++) {
                storage.put(i, (int)(Math.random()*100));
            }
            for (int i : storage.keySet()) {
                System.out.print("(" + i + "," + storage.get(i) + ") ");
            }
            System.out.println();
        }
    }
}

它放入从 0 到 9 的 ConcurrentHashMap storage 键，并为它们分配一个介于 0 和 0 之间的随机值100。之后它会打印它并在末尾打印新行。我有用户 synchronized block 来确保线程本身正确访问 key ，但它打印如下内容:

(0,8) (0,87) (1,60) (1,14) (2,20) (2,70) (3,5) (0,74) (0,42) (1,22) (4,96) (0,85) (1,97) (2,75) (3,68) (4,3) (5,49) (6,3) (7,9) (8,47) (9,52) 
(3,2) (5,74) (2,86) (1,48) (3,5) (6,0) (4,0) (7,86) (4,22) (8,20) (2,17) (9,87) 
(5,96) (5,15) (6,15) (6,92) (7,48) (8,93) (9,67) 
(3,87) (7,43) (4,34) (5,48) (8,91) (9,64) 
(6,84) (7,75) (8,47) (9,87) 

这显然意味着某个线程打印了我分配给它的 10 个以上的键。如何让每个线程准确打印分配给它们的 10 个键和值并确保此处的并发性？

我不知道如何测试它。

Answer 1

您的线程不共享任何内部状态。它们工作正常，但输出是交错的。

例如，如果您使用 StringBuilder 在一次操作中执行 I/O，您应该会看到正确的输出。

        StringBuilder buff = new StringBuilder();
        for (int i : storage.keySet()) {
            buff.append("(" + i + "," + storage.get(i) + ") ");
        }
        System.out.println(buff);

没有充分的理由让Server成为Runnable，甚至创建它的任何实例。

您没有共享任何 map 。如果您这样做了，那么您还想共享一个公共(public)锁，但这不是使用 ConcurrentMap 的常用方法。