-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathSyncMap2.java
More file actions
74 lines (60 loc) · 1.85 KB
/
SyncMap2.java
File metadata and controls
74 lines (60 loc) · 1.85 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
package syncmap;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
class Producer extends Thread {
Map<String, Integer> sm;
Producer(Map<String, Integer> sm, String name){
this.sm=sm;
setName("PRODUCER:"+name);
}
public void run() {
System.out.println(this.getName()+" :: Producer::run() : Starting ");
try {
int i=0;
while(i<10){
System.out.println(this.getName()+" :: adding ... "+i);
sm.putIfAbsent(this.getName(), i);
}
i++;
} catch (Exception e) {
e.printStackTrace();
}
}
}
class Consumer extends Thread{
Map<String, Integer> sm;
Consumer(Map<String, Integer> sm){
this.sm=sm;
setName("CONSUMER");
}
public void run() {
System.out.println(this.getName()+" :: Consumer::run() : Starting ");
try {
while(true){
// System.out.println(" ------- "+this.getName()+" :: "+sq.take());
for(String key:sm.keySet()){
System.out.println(" ------- "+this.getName()+" :: "+key +" :: value = "+sm.get(key));
sm.remove(key);
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
public class SyncMap2 {
public static void main(String... args) {
Map<String, Integer> sm = Collections.synchronizedMap(new HashMap<String, Integer>());
// SynchronousQueue<String> sq = new SynchronousQueue<String>();
System.out.println("main() : Starting ");
new Consumer(sm).start();
new Producer(sm,"A").start();
new Producer(sm,"B").start();
new Producer(sm,"C").start();
new Producer(sm,"D").start();
new Producer(sm,"E").start();
new Producer(sm,"F").start();
System.out.println("main() : End ");
}
}