Add test on work stealing pool
@@ -15,6 +15,7 @@ import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.Future;
@@ -46,6 +47,12 @@ abstract class ExecutorInstrumentationTest<T extends ExecutorService>
}
}
+ static class WorkStealingPoolTest extends ExecutorInstrumentationTest<ExecutorService> {
+ public WorkStealingPoolTest() {
+ super(Executors.newWorkStealingPool(2));
+ }
+ }
+
static class ScheduledThreadPoolExecutorTest
extends ExecutorInstrumentationTest<ScheduledThreadPoolExecutor> {
ScheduledThreadPoolExecutorTest() {
