-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathDataMover.java
64 lines (47 loc) · 2.13 KB
/
DataMover.java
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
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
public class DataMover {
public static int [] data = new int[3];
public static List<Thread> movers = new ArrayList<>();
public static void main (String [] args) {
final int [] arguments;
if (args.length == 0) { arguments = new int[] {123, 111, 256, 404}; }
else {
arguments = new int[args.length];
IntStream.range(0, args.length).forEach(x -> arguments[x] = Integer.parseInt(args[x]));
}
final int moveTime = arguments[0];
data = new int[arguments.length-1];
IntStream.range(0, data.length).forEach(i -> {
data[i] = i*1000;
final int sleepTime = arguments[i+1];
final int finalI = i;
movers.add(new Thread(() -> {
IntStream.range(0,10).forEach(x -> {
try { Thread.sleep(sleepTime); } catch (InterruptedException e) {}
synchronized(data) {
data[finalI] = data[finalI] - finalI;
System.out.println("#"+ finalI + ": data " + finalI + " == " + data[finalI]);
}
try { Thread.sleep(moveTime); } catch (InterruptedException e) {}
synchronized(data) {
int nextI = finalI + 1 >= data.length ? 0 : finalI + 1;
data[nextI] += finalI;
System.out.println("#"+ finalI + ": data " + nextI + " == " + data[nextI]);
}
});
}, Integer.toString(i)));
});
IntStream.range(0, movers.size()).forEach(x -> movers.get(x).start());
IntStream.range(0, movers.size()).forEach(x -> {
try { movers.get(x).join(); } catch (InterruptedException e) {}
}
);
System.out.println(Arrays.stream(data)
.mapToObj(Integer::valueOf)
.collect(Collectors.toList()));
}
}