iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BAEL-20599: Increase blocking operations' time

This commit is contained in:
Krzysztof Woyke 2020-01-21 09:53:09 +01:00
parent 7d88ce8e4a
commit 0dc6b27fa6
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
core-java-modules/core-java-concurrency-advanced-3/src/test/java/com/baeldung/rejection/SaturationPolicyUnitTest.java
View File

@ -31,7 +31,7 @@ public class SaturationPolicyUnitTest {
@Test @Test
public void givenAbortPolicy_WhenSaturated_ThenShouldThrowRejectedExecutionException() { public void givenAbortPolicy_WhenSaturated_ThenShouldThrowRejectedExecutionException() {
executor = new ThreadPoolExecutor(1, 1, 0, MILLISECONDS, new SynchronousQueue<>(), new AbortPolicy()); executor = new ThreadPoolExecutor(1, 1, 0, MILLISECONDS, new SynchronousQueue<>(), new AbortPolicy());
executor.execute(() -> waitFor(100)); executor.execute(() -> waitFor(250));
assertThatThrownBy(() -> executor.execute(() -> System.out.println("Will be rejected"))).isInstanceOf(RejectedExecutionException.class); assertThatThrownBy(() -> executor.execute(() -> System.out.println("Will be rejected"))).isInstanceOf(RejectedExecutionException.class);
} }
@ -39,13 +39,13 @@ public class SaturationPolicyUnitTest {
@Test @Test
public void givenCallerRunsPolicy_WhenSaturated_ThenTheCallerThreadRunsTheTask() { public void givenCallerRunsPolicy_WhenSaturated_ThenTheCallerThreadRunsTheTask() {
executor = new ThreadPoolExecutor(1, 1, 0, MILLISECONDS, new SynchronousQueue<>(), new CallerRunsPolicy()); executor = new ThreadPoolExecutor(1, 1, 0, MILLISECONDS, new SynchronousQueue<>(), new CallerRunsPolicy());
executor.execute(() -> waitFor(100)); executor.execute(() -> waitFor(250));
long startTime = System.nanoTime(); long startTime = System.currentTimeMillis();
executor.execute(() -> waitFor(100)); executor.execute(() -> waitFor(500));
double blockedDuration = (System.nanoTime() - startTime) / 1_000_000.0; long blockedDuration = System.currentTimeMillis() - startTime;
assertThat(blockedDuration).isGreaterThanOrEqualTo(100); assertThat(blockedDuration).isGreaterThanOrEqualTo(500);
} }
@Test @Test