summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMichael Bien <[email protected]>2011-08-03 18:56:07 +0200
committerMichael Bien <[email protected]>2011-08-03 18:56:07 +0200
commit0ee9b79f5941c5d418b8daa82783ed67fc3efeb4 (patch)
treead5ad150e15993a6039b082ccd0bb70e50f912cd
parent7ca1a00e19608673b13c1eeb3b0d1141d8043173 (diff)
renamed CLAbstractExecutorService -> CLExecutorService.
-rw-r--r--src/com/jogamp/opencl/util/concurrent/CLCommandQueuePool.java2
-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.java2
-rw-r--r--src/com/jogamp/opencl/util/concurrent/CLRecursiveTask.java2
-rw-r--r--src/com/jogamp/opencl/util/concurrent/CLTaskCompletionService.java8
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;
}