Fix tests
This commit is contained in:
parent
934fc3ff39
commit
6bda038a28
@ -8,6 +8,7 @@ import java.util.concurrent.TimeUnit;
|
|||||||
import java.util.concurrent.atomic.LongAdder;
|
import java.util.concurrent.atomic.LongAdder;
|
||||||
import java.util.stream.IntStream;
|
import java.util.stream.IntStream;
|
||||||
|
|
||||||
|
import static com.jayway.awaitility.Awaitility.await;
|
||||||
import static junit.framework.TestCase.assertEquals;
|
import static junit.framework.TestCase.assertEquals;
|
||||||
|
|
||||||
public class LongAdderTest {
|
public class LongAdderTest {
|
||||||
@ -60,6 +61,7 @@ public class LongAdderTest {
|
|||||||
executorService.shutdown();
|
executorService.shutdown();
|
||||||
|
|
||||||
assertEquals(counter.sumThenReset(), numberOfIncrements * numberOfThreads);
|
assertEquals(counter.sumThenReset(), numberOfIncrements * numberOfThreads);
|
||||||
assertEquals(counter.sum(), 0);
|
|
||||||
|
await().until(() -> assertEquals(counter.sum(), 0));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user