From 8ae52459adcde3532b9af81a4752dbd3883d2e75 Mon Sep 17 00:00:00 2001 From: Ali Dehghani Date: Wed, 20 Nov 2019 08:05:39 +0330 Subject: [PATCH] Sample codes for RejectedExecutionHandler article. --- .../baeldung/rejection/SaturationPolicyUnitTest.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/core-java-modules/core-java-concurrency-advanced-2/src/test/java/com/baeldung/rejection/SaturationPolicyUnitTest.java b/core-java-modules/core-java-concurrency-advanced-2/src/test/java/com/baeldung/rejection/SaturationPolicyUnitTest.java index fa0f299c4c..83f1d49a1b 100644 --- a/core-java-modules/core-java-concurrency-advanced-2/src/test/java/com/baeldung/rejection/SaturationPolicyUnitTest.java +++ b/core-java-modules/core-java-concurrency-advanced-2/src/test/java/com/baeldung/rejection/SaturationPolicyUnitTest.java @@ -33,8 +33,7 @@ public class SaturationPolicyUnitTest { executor = new ThreadPoolExecutor(1, 1, 0, MILLISECONDS, new SynchronousQueue<>(), new AbortPolicy()); executor.execute(() -> waitFor(100)); - assertThatThrownBy(() -> executor.execute(() -> System.out.println("Will be rejected"))) - .isInstanceOf(RejectedExecutionException.class); + assertThatThrownBy(() -> executor.execute(() -> System.out.println("Will be rejected"))).isInstanceOf(RejectedExecutionException.class); } @Test @@ -97,8 +96,7 @@ public class SaturationPolicyUnitTest { ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 0, MILLISECONDS, new LinkedBlockingQueue<>()); executor.shutdownNow(); - assertThatThrownBy(() -> executor.execute(() -> {})) - .isInstanceOf(RejectedExecutionException.class); + assertThatThrownBy(() -> executor.execute(() -> {})).isInstanceOf(RejectedExecutionException.class); } @Test @@ -107,8 +105,8 @@ public class SaturationPolicyUnitTest { executor.execute(() -> waitFor(100)); executor.shutdown(); - assertThatThrownBy(() -> executor.execute(() -> {})) - .isInstanceOf(RejectedExecutionException.class); + assertThatThrownBy(() -> executor.execute(() -> { + })).isInstanceOf(RejectedExecutionException.class); } private static class GrowPolicy implements RejectedExecutionHandler {