diff options
author | Michael Bien <[email protected]> | 2011-08-03 18:56:07 +0200 |
---|---|---|
committer | Michael Bien <[email protected]> | 2011-08-03 18:56:07 +0200 |
commit | 0ee9b79f5941c5d418b8daa82783ed67fc3efeb4 (patch) | |
tree | ad5ad150e15993a6039b082ccd0bb70e50f912cd | |
parent | 7ca1a00e19608673b13c1eeb3b0d1141d8043173 (diff) |
renamed CLAbstractExecutorService -> CLExecutorService.
-rw-r--r-- | src/com/jogamp/opencl/util/concurrent/CLCommandQueuePool.java | 2 | ||||
-rw-r--r-- | src/com/jogamp/opencl/util/concurrent/CLExecutorService.java (renamed from src/com/jogamp/opencl/util/concurrent/CLAbstractExecutorService.java) | 4 | ||||
-rw-r--r-- | src/com/jogamp/opencl/util/concurrent/CLForkJoinPool.java | 2 | ||||
-rw-r--r-- | src/com/jogamp/opencl/util/concurrent/CLRecursiveTask.java | 2 | ||||
-rw-r--r-- | src/com/jogamp/opencl/util/concurrent/CLTaskCompletionService.java | 8 |
5 files changed, 9 insertions, 9 deletions
diff --git a/src/com/jogamp/opencl/util/concurrent/CLCommandQueuePool.java b/src/com/jogamp/opencl/util/concurrent/CLCommandQueuePool.java index d9025881..b463fa03 100644 --- a/src/com/jogamp/opencl/util/concurrent/CLCommandQueuePool.java +++ b/src/com/jogamp/opencl/util/concurrent/CLCommandQueuePool.java @@ -56,7 +56,7 @@ import java.util.concurrent.TimeUnit; * </p> * @author Michael Bien */ -public class CLCommandQueuePool extends CLAbstractExecutorService { +public class CLCommandQueuePool extends CLExecutorService { private CLCommandQueuePool(ExecutorService executor, List<CLCommandQueue> queues) { diff --git a/src/com/jogamp/opencl/util/concurrent/CLAbstractExecutorService.java b/src/com/jogamp/opencl/util/concurrent/CLExecutorService.java index b94aa85f..5878bbdf 100644 --- a/src/com/jogamp/opencl/util/concurrent/CLAbstractExecutorService.java +++ b/src/com/jogamp/opencl/util/concurrent/CLExecutorService.java @@ -62,7 +62,7 @@ import java.util.concurrent.TimeoutException; * </p> * @author Michael Bien */ -public abstract class CLAbstractExecutorService implements CLResource { +public abstract class CLExecutorService implements CLResource { protected final ExecutorService excecutor; protected final List<CLCommandQueue> queues; @@ -70,7 +70,7 @@ public abstract class CLAbstractExecutorService implements CLResource { private FinishAction finishAction = FinishAction.DO_NOTHING; private boolean released; - protected CLAbstractExecutorService(ExecutorService executor, List<CLCommandQueue> queues) { + protected CLExecutorService(ExecutorService executor, List<CLCommandQueue> queues) { this.queues = queues; this.excecutor = executor; } diff --git a/src/com/jogamp/opencl/util/concurrent/CLForkJoinPool.java b/src/com/jogamp/opencl/util/concurrent/CLForkJoinPool.java index 93c1dbc4..cad1dfc8 100644 --- a/src/com/jogamp/opencl/util/concurrent/CLForkJoinPool.java +++ b/src/com/jogamp/opencl/util/concurrent/CLForkJoinPool.java @@ -50,7 +50,7 @@ import java.util.concurrent.Future; * @see CLRecursiveTask * @author Michael Bien */ -public class CLForkJoinPool extends CLAbstractExecutorService { +public class CLForkJoinPool extends CLExecutorService { private CLForkJoinPool(ExecutorService executor, List<CLCommandQueue> queues) { super(executor, queues); diff --git a/src/com/jogamp/opencl/util/concurrent/CLRecursiveTask.java b/src/com/jogamp/opencl/util/concurrent/CLRecursiveTask.java index 14dd4494..c0583b0b 100644 --- a/src/com/jogamp/opencl/util/concurrent/CLRecursiveTask.java +++ b/src/com/jogamp/opencl/util/concurrent/CLRecursiveTask.java @@ -30,7 +30,7 @@ package com.jogamp.opencl.util.concurrent; import com.jogamp.opencl.CLCommandQueue; -import com.jogamp.opencl.util.concurrent.CLAbstractExecutorService.CommandQueueThread; +import com.jogamp.opencl.util.concurrent.CLExecutorService.CommandQueueThread; import java.util.concurrent.RecursiveTask; /** diff --git a/src/com/jogamp/opencl/util/concurrent/CLTaskCompletionService.java b/src/com/jogamp/opencl/util/concurrent/CLTaskCompletionService.java index a6d5f794..09725f3e 100644 --- a/src/com/jogamp/opencl/util/concurrent/CLTaskCompletionService.java +++ b/src/com/jogamp/opencl/util/concurrent/CLTaskCompletionService.java @@ -36,7 +36,7 @@ import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; /** - * A {@link CompletionService} for {@link CLTask}s executed in a {@link CLAbstractExecutorService}. + * A {@link CompletionService} for {@link CLTask}s executed in a {@link CLExecutorService}. * It simplifies asynchronous execution of tasks with the same result type in a potentially shared pool. * @see CompletionService * @author Michael Bien @@ -44,14 +44,14 @@ import java.util.concurrent.TimeUnit; public class CLTaskCompletionService<R> { private final ExecutorCompletionService<R> service; - private final CLAbstractExecutorService executor; + private final CLExecutorService executor; /** * Creates an CLTaskCompletionService using the supplied executor for base * task execution and a LinkedBlockingQueue with the capacity of {@link Integer#MAX_VALUE} * as a completion queue. */ - public CLTaskCompletionService(CLAbstractExecutorService executor) { + public CLTaskCompletionService(CLExecutorService executor) { this.service = new ExecutorCompletionService<R>(executor.getExcecutor()); this.executor = executor; } @@ -60,7 +60,7 @@ public class CLTaskCompletionService<R> { * Creates an CLTaskCompletionService using the supplied executor for base * task execution the supplied queue as its completion queue. */ - public CLTaskCompletionService(CLAbstractExecutorService pool, BlockingQueue<Future<R>> queue) { + public CLTaskCompletionService(CLExecutorService pool, BlockingQueue<Future<R>> queue) { this.service = new ExecutorCompletionService<R>(pool.getExcecutor(), queue); this.executor = pool; } |