commonPool on CI doesn't work sometimes

Author: akarnokd

src/test/java/hu/akarnokd/asyncenum/AsyncObserveOnTest.java

@@ -3,7 +3,7 @@
 import org.junit.Test;
 
 import java.util.List;
-import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.*;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertTrue;
@@ -12,16 +12,20 @@ public class AsyncObserveOnTest {
 
     @Test
     public void simple() {
-        List<String> list = AsyncEnumerable.range(1, 5)
-                .observeOn(ForkJoinPool.commonPool())
-                .map(v -> v + " " + Thread.currentThread().getName())
-                .toList()
-                .blockingFirst();
+        ExecutorService exec = Executors.newSingleThreadExecutor(r -> new Thread(r, "CustomPool"));
+        try {
+            List<String> list = AsyncEnumerable.range(1, 5)
+                    .observeOn(exec)
+                    .map(v -> v + " " + Thread.currentThread().getName())
+                    .toList()
+                    .blockingFirst();
 
-        assertEquals(5, list.size());
-        for (String s : list) {
-            assertTrue(s, s.contains("ForkJoinPool"));
+            assertEquals(5, list.size());
+            for (String s : list) {
+                assertTrue(s, s.contains("CustomPool"));
+            }
+        } finally {
+            exec.shutdownNow();
         }
-
     }
 }

src/test/java/hu/akarnokd/asyncenum/AsyncSubscribeOnTest.java

@@ -3,7 +3,7 @@
 import org.junit.Test;
 
 import java.util.List;
-import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.*;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertTrue;
@@ -12,15 +12,20 @@ public class AsyncSubscribeOnTest {
 
     @Test
     public void simple() {
-        List<String> list = AsyncEnumerable.range(1, 5)
-                .subscribeOn(ForkJoinPool.commonPool())
-                .map(v -> v + " " + Thread.currentThread().getName())
-                .toList()
-                .blockingFirst();
+        ExecutorService exec = Executors.newSingleThreadExecutor(r -> new Thread(r, "CustomPool"));
+        try {
+            List<String> list = AsyncEnumerable.range(1, 5)
+                    .subscribeOn(exec)
+                    .map(v -> v + " " + Thread.currentThread().getName())
+                    .toList()
+                    .blockingFirst();
 
-        assertEquals(5, list.size());
-        for (String s : list) {
-            assertTrue(s, s.contains("ForkJoinPool"));
+            assertEquals(5, list.size());
+            for (String s : list) {
+                assertTrue(s, s.contains("CustomPool"));
+            }
+        } finally {
+            exec.shutdownNow();
         }
     }
 }