Skip to content

Commit 7d6e425

Browse files
committed
Remove gracefullyFinishThreads
1 parent 0c52fc6 commit 7d6e425

File tree

3 files changed

+0
-19
lines changed

3 files changed

+0
-19
lines changed

vavr/src/test/java/io/vavr/concurrent/Concurrent.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -75,13 +75,4 @@ static <T, X extends Throwable> CheckedFunction0<T> zZz(X exception) {
7575
throw exception;
7676
};
7777
}
78-
79-
static void gracefullyFinishThreads() throws TimeoutException {
80-
final boolean isQuiescent = ForkJoinPool.commonPool().awaitQuiescence(1L, TimeUnit.MINUTES);
81-
if (isQuiescent) {
82-
System.out.println("ForkJoinPool.commonPool() is quiecent");
83-
} else {
84-
throw new TimeoutException("Timeout while waiting for running threads in ForkJoinPool.commonPool() to finish.");
85-
}
86-
}
8778
}

vavr/src/test/java/io/vavr/concurrent/FutureTest.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -70,11 +70,6 @@ public class FutureTest extends AbstractValueTest {
7070

7171
private static final Executor REJECTING_EXECUTOR = ignored -> {throw new RejectedExecutionException();};
7272

73-
@AfterAll
74-
public static void gracefullyFinishThreads() throws TimeoutException {
75-
Concurrent.gracefullyFinishThreads();
76-
}
77-
7873
static class TraceUnitExtension implements AfterEachCallback, BeforeEachCallback {
7974

8075
@Override

vavr/src/test/java/io/vavr/concurrent/PromiseTest.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -28,11 +28,6 @@
2828

2929
public class PromiseTest {
3030

31-
@AfterAll
32-
public static void gracefullyFinishThreads() throws TimeoutException {
33-
Concurrent.gracefullyFinishThreads();
34-
}
35-
3631
@Test
3732
public void shouldReturnExecutorService() {
3833
final Promise<Integer> promise = Promise.successful(42);

0 commit comments

Comments
 (0)