org.instrumentmiddleware.cima.util
Class SerialExecutorService

java.lang.Object
  org.instrumentmiddleware.cima.util.SerialExecutorService

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public class SerialExecutorService
extends java.lang.Object
implements java.util.concurrent.ExecutorService

Nested Class Summary

class

SerialExecutorService.SimpleFuture<T>

Constructor Summary

SerialExecutorService()

Method Summary

boolean	awaitTermination(long arg0, java.util.concurrent.TimeUnit arg1)
void	execute(java.lang.Runnable arg0)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0, long arg1, java.util.concurrent.TimeUnit arg2) because this is running in the same thread as the caller, I'm not going to watch for the timeout because it's too much work :)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0, long arg1, java.util.concurrent.TimeUnit arg2)
boolean	isShutdown()
boolean	isTerminated()
void	shutdown()
java.util.List<java.lang.Runnable>	shutdownNow()
<T> java.util.concurrent.Future<T>	submit(java.util.concurrent.Callable<T> arg0)
java.util.concurrent.Future<?>	submit(java.lang.Runnable arg0)
<T> java.util.concurrent.Future<T>	submit(java.lang.Runnable arg0, T arg1)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.concurrent.ExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Constructor Detail

SerialExecutorService

public SerialExecutorService()

Method Detail

awaitTermination

public boolean awaitTermination(long arg0,
                                java.util.concurrent.TimeUnit arg1)
                         throws java.lang.InterruptedException

Specified by:

awaitTermination in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0)
                                                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0,
                                                                    long arg1,
                                                                    java.util.concurrent.TimeUnit arg2)
                                                         throws java.lang.InterruptedException

because this is running in the same thread as the caller, I'm not going to watch for the timeout because it's too much work :)

Throws:

java.lang.InterruptedException

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0)
            throws java.lang.InterruptedException,
                   java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0,
                       long arg1,
                       java.util.concurrent.TimeUnit arg2)
            throws java.lang.InterruptedException,
                   java.util.concurrent.ExecutionException,
                   java.util.concurrent.TimeoutException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface java.util.concurrent.ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface java.util.concurrent.ExecutorService

shutdown

public void shutdown()

Specified by:

shutdown in interface java.util.concurrent.ExecutorService

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

Specified by:

shutdownNow in interface java.util.concurrent.ExecutorService

submit

public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> arg0)

Specified by:

submit in interface java.util.concurrent.ExecutorService

submit

public java.util.concurrent.Future<?> submit(java.lang.Runnable arg0)

Specified by:

submit in interface java.util.concurrent.ExecutorService

submit

public <T> java.util.concurrent.Future<T> submit(java.lang.Runnable arg0,
                                                 T arg1)

Specified by:

submit in interface java.util.concurrent.ExecutorService

execute

public void execute(java.lang.Runnable arg0)

Specified by:

execute in interface java.util.concurrent.Executor