@@ -0,0 +1,719 @@
+package com.github.ferstl;%0A%0Aimport java.util.Arrays;%0Aimport java.util.concurrent.ForkJoinPool;%0Aimport java.util.concurrent.TimeUnit;%0Aimport org.junit.After;%0Aimport org.junit.Before;%0Aimport org.junit.Test;%0A%0A%0Apublic class ParallelStreamSupportTest %7B%0A%0A  private ForkJoinPool workerPool;%0A%0A  @Before%0A  public void before() %7B%0A    this.workerPool = new ForkJoinPool(1);%0A  %7D%0A%0A  @After%0A  public void after() throws InterruptedException %7B%0A    this.workerPool.shutdown();%0A    this.workerPool.awaitTermination(1, TimeUnit.SECONDS);%0A  %7D%0A%0A%0A  @Test%0A  public void test() %7B%0A    ParallelStreamSupport.parallelStream(Arrays.asList(%22a%22), this.workerPool)%0A        .forEach(e -%3E System.out.println(Thread.currentThread().getName()));%0A  %7D%0A%0A%7D%0A

Add test