fixed code for failing tests
This commit is contained in:
@@ -4,6 +4,7 @@ import java.util.concurrent.BrokenBarrierException;
|
||||
import java.util.concurrent.CyclicBarrier;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
public class CyclicBarrierCompletionMethodExample {
|
||||
@@ -35,6 +36,11 @@ public class CyclicBarrierCompletionMethodExample {
|
||||
});
|
||||
}
|
||||
es.shutdown();
|
||||
try {
|
||||
es.awaitTermination(1, TimeUnit.SECONDS);
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return updateCount.get();
|
||||
}
|
||||
|
||||
|
||||
@@ -4,6 +4,7 @@ import java.util.concurrent.BrokenBarrierException;
|
||||
import java.util.concurrent.CyclicBarrier;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
public class CyclicBarrierResetExample {
|
||||
@@ -36,6 +37,11 @@ public class CyclicBarrierResetExample {
|
||||
});
|
||||
}
|
||||
es.shutdown();
|
||||
try {
|
||||
es.awaitTermination(1, TimeUnit.SECONDS);
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return updateCount.get();
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user