diff --git a/u07-2/SimpleExecutorCompletionService_with_take.java b/u07-2/SimpleExecutorCompletionService_with_take.java index 4486e87..c7b783e 100644 --- a/u07-2/SimpleExecutorCompletionService_with_take.java +++ b/u07-2/SimpleExecutorCompletionService_with_take.java @@ -64,16 +64,16 @@ public class SimpleExecutorCompletionService_with_take { synchronized private void updateFuturesLists() { - for (int i = 0; i < this.pendingFutures.size(); i++) { - Future f = this.pendingFutures.get(i); + // for (int i = 0; i < this.pendingFutures.size(); i++) { + for (Future f : this.pendingFutures) { + // Future f = this.pendingFutures.get(i); - // for (Future f : this.pendingFutures) { // causes concurrent access exception - why? if (f.isDone()) { this.pendingFutures.remove(f); this.doneFutures.add(f); - notify(); + //notify(); } }