@Test
public void testFlowWithCommonForkJoinPool() throws Exception {

    pool = ForkJoinPool.commonPool();
    List<CompletableFuture<Integer>> futures = new ArrayList<>();
    for (int i = 0; i < 20; i++) {
        futures.add(
                CompletableFutureFlow.flowWithId(i, pool));
    }
    futures.forEach(CompletableFutureFlow::getFuture);
}