org.jboss.threads
Class ProtectedExecutorService

java.lang.Object
  extended by java.util.concurrent.AbstractExecutorService
      extended by org.jboss.threads.ProtectedExecutorService
All Implemented Interfaces:
java.util.concurrent.Executor, java.util.concurrent.ExecutorService
Direct Known Subclasses:
ProtectedDirectExecutorService, ProtectedScheduledExecutorService

public class ProtectedExecutorService
extends java.util.concurrent.AbstractExecutorService
implements java.util.concurrent.ExecutorService

An implementation of ExecutorService that delegates to the real executor, while disallowing termination.


Constructor Summary
ProtectedExecutorService(java.util.concurrent.Executor delegate)
           
 
Method Summary
 boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
           
static java.util.concurrent.ExecutorService directExecutorService()
           
 void execute(java.lang.Runnable command)
           
 boolean isShutdown()
           
 boolean isTerminated()
           
 void shutdown()
           
 java.util.List<java.lang.Runnable> shutdownNow()
           
 
Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit
 
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, submit, submit, submit
 

Constructor Detail

ProtectedExecutorService

public ProtectedExecutorService(java.util.concurrent.Executor delegate)
Method Detail

execute

public void execute(java.lang.Runnable command)
Specified by:
execute in interface java.util.concurrent.Executor

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

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException
Specified by:
awaitTermination in interface java.util.concurrent.ExecutorService
Throws:
java.lang.InterruptedException

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

directExecutorService

public static java.util.concurrent.ExecutorService directExecutorService()


Copyright © 2011. All Rights Reserved.