eric/OnJava8-Examples
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Doesn't need CopyOnWrite

Browse Source
This commit is contained in:
Bruce Eckel 2017-01-14 15:49:57 -08:00
parent fed9a0993b
commit a179863adb
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lowlevel/DelayQueueDemo.java
View File

@ -13,7 +13,7 @@ class DelayedTask implements Runnable, Delayed {
private final int delta;
private final long trigger;
protected static List<DelayedTask> sequence =
new CopyOnWriteArrayList<>();
new ArrayList<>();
public DelayedTask(int delayInMilliseconds) {
delta = delayInMilliseconds;
trigger = System.nanoTime() +
@ -49,7 +49,7 @@ class DelayedTask implements Runnable, Delayed {
@Override
public void run() {
sequence.forEach(dt ->
System.out.println(dt.summary() + " "));
System.out.println(dt.summary()));
}
}
}
@ -58,8 +58,7 @@ public class DelayQueueDemo {
public static void
main(String[] args) throws Exception {
DelayQueue<DelayedTask> tasks =
Stream.concat(
// Tasks with random delays:
Stream.concat( // Random delays:
new Random(47).ints(20, 0, 4000)
.mapToObj(DelayedTask::new),
// Add the summarizing task: