Repository navigation
Expand file tree
/
Copy pathExchangerExample.java
More file actions
72 lines (62 loc) · 1.99 KB
/
Copy pathExchangerExample.java
File metadata and controls
72 lines (62 loc) · 1.99 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
import java.util.concurrent.*;
public class ExchangerExample {
public static void main(String[] args) throws InterruptedException {
Exchanger<String> exchanger = new Exchanger();
StringConstructor stringConstructor = new StringConstructor(exchanger);
StringProcessor stringProcessor = new StringProcessor(exchanger);
Thread stringConstructorThread = new Thread(() -> stringConstructor.construct());
Thread stringProcessorThread = new Thread(() -> stringProcessor.process());
stringConstructorThread.start();
stringProcessorThread.start();
stringConstructorThread.join();
stringProcessorThread.join();
}
}
public class StringConstructor {
private Exchanger<String> exchanger;
public StringConstructor(Exchanger<String> exchanger) {
this.exchanger = exchanger;
}
public void construct() {
StringBuilder sb = new StringBuilder();
for (char c = 'a', count = 0; c <= 'z'; c++, count++) {
sb.append(c);
if (count % 3 == 0) {
try {
exchanger.exchange(sb.toString());
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
try {
exchanger.exchange(sb.toString());
exchanger.exchange("EOS");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public class StringProcessor {
private Exchanger<String> exchanger;
public StringProcessor(Exchanger<String> exchanger) {
this.exchanger = exchanger;
}
public void process() {
String str = "";
try {
str = exchanger.exchange("");
} catch (InterruptedException e) {
e.printStackTrace();
}
while (str != "EOS") {
System.out.println(str);
try {
str = exchanger.exchange("");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}