akka.dispatch
Class ExecutionContexts.sameThreadExecutionContext$

java.lang.Object
  extended by akka.dispatch.ExecutionContexts.sameThreadExecutionContext$
All Implemented Interfaces:
BatchingExecutor, java.util.concurrent.Executor, scala.concurrent.ExecutionContext
Enclosing class:
ExecutionContexts

public static class ExecutionContexts.sameThreadExecutionContext$
extends java.lang.Object
implements scala.concurrent.ExecutionContext, BatchingExecutor

WARNING: Not A General Purpose ExecutionContext!

This is an execution context which runs everything on the calling thread. It is very useful for actions which are known to be non-blocking and non-throwing in order to save a round-trip to the thread pool.


Nested Class Summary
 
Nested classes/interfaces inherited from interface scala.concurrent.ExecutionContext
scala.concurrent.ExecutionContext.Implicits$
 
Field Summary
static ExecutionContexts.sameThreadExecutionContext$ MODULE$
          Static reference to the singleton instance of this Scala object.
 
Constructor Summary
ExecutionContexts.sameThreadExecutionContext$()
           
 
Method Summary
 void reportFailure(java.lang.Throwable t)
           
protected  boolean resubmitOnBlock()
           
protected  void unbatchedExecute(java.lang.Runnable runnable)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface scala.concurrent.ExecutionContext
execute, prepare
 
Methods inherited from interface akka.dispatch.BatchingExecutor
batchable, execute
 

Field Detail

MODULE$

public static final ExecutionContexts.sameThreadExecutionContext$ MODULE$
Static reference to the singleton instance of this Scala object.

Constructor Detail

ExecutionContexts.sameThreadExecutionContext$

public ExecutionContexts.sameThreadExecutionContext$()
Method Detail

unbatchedExecute

protected void unbatchedExecute(java.lang.Runnable runnable)
Specified by:
unbatchedExecute in interface BatchingExecutor

resubmitOnBlock

protected boolean resubmitOnBlock()
Specified by:
resubmitOnBlock in interface BatchingExecutor

reportFailure

public void reportFailure(java.lang.Throwable t)
Specified by:
reportFailure in interface scala.concurrent.ExecutionContext