这是我的主类,它初始化并启动 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 个键和值并确保此处的并发性?
我不知道如何测试它。
最佳答案
您的线程不共享任何内部状态。它们工作正常,但输出是交错的。
例如,如果您使用 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
的常用方法。
关于使用 ConcurrentHashMap 和同步块(synchronized block)实现 Java 并发,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59293954/