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

Merge pull request #8560 from kwoyke/BAEL-20599 

BAEL-20599: Increase blocking operations' time
This commit is contained in:
Loredana Crusoveanu 2020-01-24 15:21:59 +02:00 committed by GitHub
parent b3170b38eb 0dc6b27fa6
commit 9446488708
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

@ -33,7 +33,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);
} }
@ -42,13 +42,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