Merge pull request #173 from scijava/executor-service

ThreadService: add API for backing ExecutorService

Author: ctrueden

src/main/java/org/scijava/thread/DefaultThreadService.java

@@ -83,6 +83,16 @@ public Future<?> run(final Runnable code) {
 		return executor().submit(wrap(code));
 	}
 
+	@Override
+	public ExecutorService getExecutorService() {
+		return executor();
+	}
+
+	@Override
+	public void setExecutorService(final ExecutorService executor) {
+		this.executor = executor;
+	}
+
 	@Override
 	public boolean isDispatchThread() {
 		return EventQueue.isDispatchThread();

src/main/java/org/scijava/thread/ThreadService.java

@@ -33,6 +33,7 @@
 
 import java.lang.reflect.InvocationTargetException;
 import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Future;
 import java.util.concurrent.ThreadFactory;
 
@@ -91,6 +92,24 @@ public enum ThreadContext {
 	 */
 	Future<?> run(Runnable code);
 
+	/**
+	 * Gets the {@link ExecutorService} object used when {@link #run} is called.
+	 * 
+	 * @return the {@link ExecutorService}, or null if an {@link ExecutorService}
+	 *         is not used in this {@link ThreadService} implementation.
+	 */
+	ExecutorService getExecutorService();
+
+	/**
+	 * Sets the {@link ExecutorService} object used when {@link #run} is called.
+	 * 
+	 * @param executor The {@link ExecutorService} for this {@link ThreadService}
+	 *          to use internally for {@link #run} calls.
+	 * @throws UnsupportedOperationException if this {@link ThreadService} does
+	 *           not use an {@link ExecutorService} to handle {@link #run} calls.
+	 */
+	void setExecutorService(ExecutorService executor);
+
 	/**
 	 * Gets whether the current thread is a dispatch thread for use with
 	 * {@link #invoke} and {@link #queue}.