From 98712a19147c22832d26bc3155e003a2795fe4de Mon Sep 17 00:00:00 2001
From: Mikolaj Izdebski <mizdebsk@redhat.com>
Date: Tue, 4 Nov 2014 12:05:10 +0100
Subject: [PATCH 1/2] JSR-166
---
src/main/groovy/groovyx/gpars/GParsPool.groovy | 14 +++++++-------
src/main/groovy/groovyx/gpars/GParsPoolUtil.java | 8 ++++----
.../groovyx/gpars/forkjoin/AbstractForkJoinWorker.java | 2 +-
src/main/groovy/groovyx/gpars/forkjoin/ForkJoinUtils.java | 4 ++--
src/main/groovy/groovyx/gpars/group/PGroupBuilder.java | 2 +-
src/main/groovy/groovyx/gpars/pa/CallAsyncTask.java | 2 +-
src/main/groovy/groovyx/gpars/pa/ClosureMapper.java | 2 +-
.../groovy/groovyx/gpars/pa/ClosureNegationPredicate.java | 2 +-
src/main/groovy/groovyx/gpars/pa/ClosurePredicate.java | 2 +-
src/main/groovy/groovyx/gpars/pa/ClosureReducer.java | 2 +-
.../groovy/groovyx/gpars/pa/GParsPoolUtilHelper.groovy | 8 ++++----
src/main/groovy/groovyx/gpars/pa/MappedPAWrapper.groovy | 2 +-
src/main/groovy/groovyx/gpars/scheduler/FJPool.java | 2 +-
src/test/groovy/groovyx/gpars/ForkJoinPoolDSLTest.groovy | 2 +-
src/test/groovy/groovyx/gpars/GParsPoolAsyncFunTest.groovy | 2 +-
src/test/groovy/groovyx/gpars/GParsPoolUtilTest.groovy | 2 +-
.../groovyx/gpars/benchmark/BenchmarkGParsPool.groovy | 2 +-
src/test/groovy/groovyx/gpars/groups/FJGroupTest.groovy | 2 +-
.../groovy/groovyx/gpars/groups/PGroupBuilderTest.groovy | 2 +-
.../groovyx/gpars/samples/forkjoin/DemoFJDirect.groovy | 6 +++---
.../samples/forkjoin/DemoRawForkJoinFileCounter.groovy | 2 +-
.../groovyx/gpars/samples/group/DemoPoolToGroup.groovy | 2 +-
22 files changed, 37 insertions(+), 37 deletions(-)
diff --git a/src/main/groovy/groovyx/gpars/GParsPool.groovy b/src/main/groovy/groovyx/gpars/GParsPool.groovy
index 4b6bfdd..f34e97c 100644
--- a/src/main/groovy/groovyx/gpars/GParsPool.groovy
+++ b/src/main/groovy/groovyx/gpars/GParsPool.groovy
@@ -20,8 +20,8 @@ import groovyx.gpars.dataflow.DataflowVariable
import groovyx.gpars.forkjoin.AbstractForkJoinWorker
import groovyx.gpars.forkjoin.ForkJoinUtils
import groovyx.gpars.util.PoolUtils
-import jsr166y.ForkJoinPool
-import jsr166y.RecursiveTask
+import java.util.concurrent.ForkJoinPool
+import java.util.concurrent.RecursiveTask
import java.lang.Thread.UncaughtExceptionHandler
import java.util.concurrent.Future
@@ -76,7 +76,7 @@ public class GParsPool {
private static createPool(int poolSize, UncaughtExceptionHandler handler) {
if (!(poolSize in 1..Integer.MAX_VALUE)) throw new IllegalArgumentException("Invalid value $poolSize for the pool size has been specified. Please supply a positive int number.")
- final jsr166y.ForkJoinPool pool = new jsr166y.ForkJoinPool(poolSize, ForkJoinPool.defaultForkJoinWorkerThreadFactory, handler, false)
+ final java.util.concurrent.ForkJoinPool pool = new java.util.concurrent.ForkJoinPool(poolSize, ForkJoinPool.defaultForkJoinWorkerThreadFactory, handler, false)
return pool
}
@@ -140,7 +140,7 @@ public class GParsPool {
* @param cl The block of code to invoke with the DSL enabled
*/
public static withPool(int numberOfThreads, UncaughtExceptionHandler handler, Closure cl) {
- final jsr166y.ForkJoinPool pool = createPool(numberOfThreads, handler)
+ final java.util.concurrent.ForkJoinPool pool = createPool(numberOfThreads, handler)
try {
return withExistingPool(pool, cl)
} finally {
@@ -165,7 +165,7 @@ public class GParsPool {
*}* </pre>
* @param pool The thread pool to use, the pool will not be shutdown after this method returns
*/
- public static withExistingPool(jsr166y.ForkJoinPool pool, Closure cl) {
+ public static withExistingPool(java.util.concurrent.ForkJoinPool pool, Closure cl) {
currentPoolStack << pool
def result = null
@@ -184,7 +184,7 @@ public class GParsPool {
* Just like withExistingPool() registers a thread pool, but doesn't install the GParsPoolUtil category.
* Used by ParallelEnhancer's Parallel mixins.
*/
- static ensurePool(final jsr166y.ForkJoinPool pool, final Closure cl) {
+ static ensurePool(final java.util.concurrent.ForkJoinPool pool, final Closure cl) {
currentPoolStack << pool
try {
return cl(pool)
@@ -226,7 +226,7 @@ public class GParsPool {
* @return Futures for the result values or exceptions of all closures
*/
public static List<Future<Object>> executeAsync(Closure... closures) {
- jsr166y.ForkJoinPool pool = retrieveCurrentPool()
+ java.util.concurrent.ForkJoinPool pool = retrieveCurrentPool()
if (pool == null) throw new IllegalStateException("No active Fork/Join thread pool available to execute closures asynchronously. Consider wrapping the function call with GParsPool.withPool().")
List<Future<Object>> result = closures.collect { cl ->
pool.submit(new MyCancellableRecursiveTask(cl))
diff --git a/src/main/groovy/groovyx/gpars/GParsPoolUtil.java b/src/main/groovy/groovyx/gpars/GParsPoolUtil.java
index ff6aed1..8e85943 100644
--- a/src/main/groovy/groovyx/gpars/GParsPoolUtil.java
+++ b/src/main/groovy/groovyx/gpars/GParsPoolUtil.java
@@ -18,8 +18,8 @@ package groovyx.gpars;
import groovy.lang.Closure;
import groovy.time.Duration;
-import groovyx.gpars.extra166y.Ops;
-import groovyx.gpars.extra166y.ParallelArray;
+import extra166y.Ops;
+import extra166y.ParallelArray;
import groovyx.gpars.memoize.LRUProtectionStorage;
import groovyx.gpars.pa.CallAsyncTask;
import groovyx.gpars.pa.CallClosure;
@@ -33,8 +33,8 @@ import groovyx.gpars.pa.SumClosure;
import groovyx.gpars.scheduler.FJPool;
import groovyx.gpars.util.GeneralTimer;
import groovyx.gpars.util.PAUtils;
-import jsr166y.ForkJoinPool;
-import jsr166y.RecursiveTask;
+import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.RecursiveTask;
import java.util.ArrayList;
import java.util.Collection;
diff --git a/src/main/groovy/groovyx/gpars/forkjoin/AbstractForkJoinWorker.java b/src/main/groovy/groovyx/gpars/forkjoin/AbstractForkJoinWorker.java
index e8dbc51..033ecec 100644
--- a/src/main/groovy/groovyx/gpars/forkjoin/AbstractForkJoinWorker.java
+++ b/src/main/groovy/groovyx/gpars/forkjoin/AbstractForkJoinWorker.java
@@ -16,7 +16,7 @@
package groovyx.gpars.forkjoin;
-import jsr166y.RecursiveTask;
+import java.util.concurrent.RecursiveTask;
import java.util.ArrayList;
import java.util.Arrays;
diff --git a/src/main/groovy/groovyx/gpars/forkjoin/ForkJoinUtils.java b/src/main/groovy/groovyx/gpars/forkjoin/ForkJoinUtils.java
index 97b5149..8f4c758 100644
--- a/src/main/groovy/groovyx/gpars/forkjoin/ForkJoinUtils.java
+++ b/src/main/groovy/groovyx/gpars/forkjoin/ForkJoinUtils.java
@@ -16,8 +16,8 @@
package groovyx.gpars.forkjoin;
-import jsr166y.ForkJoinPool;
-import jsr166y.ForkJoinTask;
+import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.ForkJoinTask;
import java.util.concurrent.ExecutionException;
diff --git a/src/main/groovy/groovyx/gpars/group/PGroupBuilder.java b/src/main/groovy/groovyx/gpars/group/PGroupBuilder.java
index 0a2d893..b0c787a 100644
--- a/src/main/groovy/groovyx/gpars/group/PGroupBuilder.java
+++ b/src/main/groovy/groovyx/gpars/group/PGroupBuilder.java
@@ -19,7 +19,7 @@ package groovyx.gpars.group;
import groovyx.gpars.scheduler.DefaultPool;
import groovyx.gpars.scheduler.FJPool;
import groovyx.gpars.scheduler.Pool;
-import jsr166y.ForkJoinPool;
+import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.ThreadPoolExecutor;
diff --git a/src/main/groovy/groovyx/gpars/pa/CallAsyncTask.java b/src/main/groovy/groovyx/gpars/pa/CallAsyncTask.java
index e7d1d5c..6610217 100644
--- a/src/main/groovy/groovyx/gpars/pa/CallAsyncTask.java
+++ b/src/main/groovy/groovyx/gpars/pa/CallAsyncTask.java
@@ -17,7 +17,7 @@
package groovyx.gpars.pa;
import groovy.lang.Closure;
-import jsr166y.RecursiveTask;
+import java.util.concurrent.RecursiveTask;
/**
* A helper class to wrap closures for callAsync on GParsPool
diff --git a/src/main/groovy/groovyx/gpars/pa/ClosureMapper.java b/src/main/groovy/groovyx/gpars/pa/ClosureMapper.java
index df090da..2e20bc8 100644
--- a/src/main/groovy/groovyx/gpars/pa/ClosureMapper.java
+++ b/src/main/groovy/groovyx/gpars/pa/ClosureMapper.java
@@ -16,7 +16,7 @@
package groovyx.gpars.pa;
-import groovyx.gpars.extra166y.Ops;
+import extra166y.Ops;
import groovy.lang.Closure;
/**
diff --git a/src/main/groovy/groovyx/gpars/pa/ClosureNegationPredicate.java b/src/main/groovy/groovyx/gpars/pa/ClosureNegationPredicate.java
index dc2e782..22987ec 100644
--- a/src/main/groovy/groovyx/gpars/pa/ClosureNegationPredicate.java
+++ b/src/main/groovy/groovyx/gpars/pa/ClosureNegationPredicate.java
@@ -16,7 +16,7 @@
package groovyx.gpars.pa;
-import groovyx.gpars.extra166y.Ops;
+import extra166y.Ops;
import groovy.lang.Closure;
/**
diff --git a/src/main/groovy/groovyx/gpars/pa/ClosurePredicate.java b/src/main/groovy/groovyx/gpars/pa/ClosurePredicate.java
index d2fae30..620bd01 100644
--- a/src/main/groovy/groovyx/gpars/pa/ClosurePredicate.java
+++ b/src/main/groovy/groovyx/gpars/pa/ClosurePredicate.java
@@ -16,7 +16,7 @@
package groovyx.gpars.pa;
-import groovyx.gpars.extra166y.Ops;
+import extra166y.Ops;
import groovy.lang.Closure;
/**
diff --git a/src/main/groovy/groovyx/gpars/pa/ClosureReducer.java b/src/main/groovy/groovyx/gpars/pa/ClosureReducer.java
index c0a35f2..4ff7adc 100644
--- a/src/main/groovy/groovyx/gpars/pa/ClosureReducer.java
+++ b/src/main/groovy/groovyx/gpars/pa/ClosureReducer.java
@@ -16,7 +16,7 @@
package groovyx.gpars.pa;
-import groovyx.gpars.extra166y.Ops;
+import extra166y.Ops;
import groovy.lang.Closure;
/**
diff --git a/src/main/groovy/groovyx/gpars/pa/GParsPoolUtilHelper.groovy b/src/main/groovy/groovyx/gpars/pa/GParsPoolUtilHelper.groovy
index a23dfe6..b6f6fdc 100644
--- a/src/main/groovy/groovyx/gpars/pa/GParsPoolUtilHelper.groovy
+++ b/src/main/groovy/groovyx/gpars/pa/GParsPoolUtilHelper.groovy
@@ -20,15 +20,15 @@ import groovyx.gpars.GParsPool
import groovyx.gpars.GParsPoolUtil
import groovyx.gpars.TransparentParallel
import groovyx.gpars.dataflow.DataflowVariable
-import groovyx.gpars.extra166y.Ops
-import groovyx.gpars.extra166y.ParallelArray
-import groovyx.gpars.extra166y.ParallelArrayWithMapping
+import extra166y.Ops
+import extra166y.ParallelArray
+import extra166y.ParallelArrayWithMapping
import groovyx.gpars.memoize.LRUProtectionStorage
import groovyx.gpars.memoize.NullProtectionStorage
import groovyx.gpars.memoize.NullValue
import groovyx.gpars.scheduler.FJPool
import groovyx.gpars.util.PAUtils
-import jsr166y.ForkJoinPool
+import java.util.concurrent.ForkJoinPool
import java.lang.ref.ReferenceQueue
import java.lang.ref.SoftReference
diff --git a/src/main/groovy/groovyx/gpars/pa/MappedPAWrapper.groovy b/src/main/groovy/groovyx/gpars/pa/MappedPAWrapper.groovy
index 07c235e..b48938f 100644
--- a/src/main/groovy/groovyx/gpars/pa/MappedPAWrapper.groovy
+++ b/src/main/groovy/groovyx/gpars/pa/MappedPAWrapper.groovy
@@ -16,7 +16,7 @@
package groovyx.gpars.pa
-import groovyx.gpars.extra166y.ParallelArrayWithMapping
+import extra166y.ParallelArrayWithMapping
/**
* The ParallelArray wrapper used after the map() operation
diff --git a/src/main/groovy/groovyx/gpars/scheduler/FJPool.java b/src/main/groovy/groovyx/gpars/scheduler/FJPool.java
index 359e344..148be60 100644
--- a/src/main/groovy/groovyx/gpars/scheduler/FJPool.java
+++ b/src/main/groovy/groovyx/gpars/scheduler/FJPool.java
@@ -17,7 +17,7 @@
package groovyx.gpars.scheduler;
import groovyx.gpars.util.PoolUtils;
-import jsr166y.ForkJoinPool;
+import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.TimeUnit;
diff --git a/src/test/groovy/groovyx/gpars/ForkJoinPoolDSLTest.groovy b/src/test/groovy/groovyx/gpars/ForkJoinPoolDSLTest.groovy
index 5c2b6a8..9195b9d 100644
--- a/src/test/groovy/groovyx/gpars/ForkJoinPoolDSLTest.groovy
+++ b/src/test/groovy/groovyx/gpars/ForkJoinPoolDSLTest.groovy
@@ -17,7 +17,7 @@
package groovyx.gpars
import java.lang.Thread.UncaughtExceptionHandler
-import jsr166y.ForkJoinPool
+import java.util.concurrent.ForkJoinPool
import static groovyx.gpars.GParsPool.withExistingPool
import static groovyx.gpars.GParsPool.withPool
diff --git a/src/test/groovy/groovyx/gpars/GParsPoolAsyncFunTest.groovy b/src/test/groovy/groovyx/gpars/GParsPoolAsyncFunTest.groovy
index a27b200..203f2bb 100644
--- a/src/test/groovy/groovyx/gpars/GParsPoolAsyncFunTest.groovy
+++ b/src/test/groovy/groovyx/gpars/GParsPoolAsyncFunTest.groovy
@@ -19,7 +19,7 @@ package groovyx.gpars
import groovyx.gpars.dataflow.DataflowQueue
import groovyx.gpars.dataflow.Promise
import groovyx.gpars.scheduler.FJPool
-import jsr166y.RecursiveAction
+import java.util.concurrent.RecursiveAction
/**
* @author Vaclav Pech
diff --git a/src/test/groovy/groovyx/gpars/GParsPoolUtilTest.groovy b/src/test/groovy/groovyx/gpars/GParsPoolUtilTest.groovy
index a7c60fd..5c0d642 100644
--- a/src/test/groovy/groovyx/gpars/GParsPoolUtilTest.groovy
+++ b/src/test/groovy/groovyx/gpars/GParsPoolUtilTest.groovy
@@ -16,7 +16,7 @@
package groovyx.gpars
-import jsr166y.ForkJoinPool
+import java.util.concurrent.ForkJoinPool
import java.lang.Thread.UncaughtExceptionHandler
import java.util.concurrent.ConcurrentHashMap
diff --git a/src/test/groovy/groovyx/gpars/benchmark/BenchmarkGParsPool.groovy b/src/test/groovy/groovyx/gpars/benchmark/BenchmarkGParsPool.groovy
index 7932ab0..6a7e476 100644
--- a/src/test/groovy/groovyx/gpars/benchmark/BenchmarkGParsPool.groovy
+++ b/src/test/groovy/groovyx/gpars/benchmark/BenchmarkGParsPool.groovy
@@ -21,7 +21,7 @@ import groovyx.gpars.GParsPoolUtil
import groovyx.gpars.ParallelEnhancer
import groovyx.gpars.extra166y.Ops.Reducer
import groovyx.gpars.extra166y.ParallelArray
-import jsr166y.ForkJoinPool
+import java.util.concurrent.ForkJoinPool
import static groovyx.gpars.GParsPool.withExistingPool
import static groovyx.gpars.GParsPool.withPool
diff --git a/src/test/groovy/groovyx/gpars/groups/FJGroupTest.groovy b/src/test/groovy/groovyx/gpars/groups/FJGroupTest.groovy
index d879203..554c59f 100644
--- a/src/test/groovy/groovyx/gpars/groups/FJGroupTest.groovy
+++ b/src/test/groovy/groovyx/gpars/groups/FJGroupTest.groovy
@@ -21,7 +21,7 @@ import groovyx.gpars.group.DefaultPGroup
import groovyx.gpars.scheduler.DefaultPool
import groovyx.gpars.scheduler.FJPool
import java.util.concurrent.CountDownLatch
-import jsr166y.ForkJoinWorkerThread
+import java.util.concurrent.ForkJoinWorkerThread
public class FJGroupTest extends GroovyTestCase {
public void testFJGroup() {
diff --git a/src/test/groovy/groovyx/gpars/groups/PGroupBuilderTest.groovy b/src/test/groovy/groovyx/gpars/groups/PGroupBuilderTest.groovy
index b849e44..120088e 100644
--- a/src/test/groovy/groovyx/gpars/groups/PGroupBuilderTest.groovy
+++ b/src/test/groovy/groovyx/gpars/groups/PGroupBuilderTest.groovy
@@ -22,7 +22,7 @@ import groovyx.gpars.scheduler.DefaultPool
import groovyx.gpars.scheduler.Pool
import java.util.concurrent.ExecutorService
import java.util.concurrent.Executors
-import jsr166y.ForkJoinPool
+import java.util.concurrent.ForkJoinPool
class PGroupBuilderTest extends GroovyTestCase {
public void testCreationFromPool() {
diff --git a/src/test/groovy/groovyx/gpars/samples/forkjoin/DemoFJDirect.groovy b/src/test/groovy/groovyx/gpars/samples/forkjoin/DemoFJDirect.groovy
index ee8d2ac..e7f249a 100644
--- a/src/test/groovy/groovyx/gpars/samples/forkjoin/DemoFJDirect.groovy
+++ b/src/test/groovy/groovyx/gpars/samples/forkjoin/DemoFJDirect.groovy
@@ -16,9 +16,9 @@
package groovyx.gpars.samples.forkjoin
-import jsr166y.ForkJoinPool
-import jsr166y.ForkJoinTask
-import jsr166y.RecursiveTask
+import java.util.concurrent.ForkJoinPool
+import java.util.concurrent.ForkJoinTask
+import java.util.concurrent.RecursiveTask
class Fibonacci extends RecursiveTask<Integer> {
final int n;
diff --git a/src/test/groovy/groovyx/gpars/samples/forkjoin/DemoRawForkJoinFileCounter.groovy b/src/test/groovy/groovyx/gpars/samples/forkjoin/DemoRawForkJoinFileCounter.groovy
index 5356cbc..af509dd 100644
--- a/src/test/groovy/groovyx/gpars/samples/forkjoin/DemoRawForkJoinFileCounter.groovy
+++ b/src/test/groovy/groovyx/gpars/samples/forkjoin/DemoRawForkJoinFileCounter.groovy
@@ -17,7 +17,7 @@
package groovyx.gpars.samples.forkjoin
import groovyx.gpars.GParsPool
-import jsr166y.RecursiveTask
+import java.util.concurrent.RecursiveTask
/**
* Shows use of the ForkJoin mechanics to count files recursively in a directory.
diff --git a/src/test/groovy/groovyx/gpars/samples/group/DemoPoolToGroup.groovy b/src/test/groovy/groovyx/gpars/samples/group/DemoPoolToGroup.groovy
index 9f88b9c..7fe29ed 100644
--- a/src/test/groovy/groovyx/gpars/samples/group/DemoPoolToGroup.groovy
+++ b/src/test/groovy/groovyx/gpars/samples/group/DemoPoolToGroup.groovy
@@ -21,7 +21,7 @@ import groovyx.gpars.GParsPool
import groovyx.gpars.group.PGroup
import groovyx.gpars.group.PGroupBuilder
import java.util.concurrent.ExecutorService
-import jsr166y.ForkJoinPool
+import java.util.concurrent.ForkJoinPool
/**
* Demonstrates how to use existing thread pool to build an instance of PGroup and then retrieve the pool back from the group.
--
2.1.0