play.libs.concurrent

Class CustomExecutionContext

java.lang.Object

play.libs.concurrent.CustomExecutionContext

All Implemented Interfaces:

java.util.concurrent.Executor, scala.concurrent.ExecutionContext, scala.concurrent.ExecutionContextExecutor

public abstract class CustomExecutionContext
extends java.lang.Object
implements scala.concurrent.ExecutionContextExecutor

Provides a custom execution context from an Akka dispatcher. Subclass this to create your own custom execution context, using the full path to the Akka dispatcher.

 
 class MyCustomExecutionContext extends CustomExecutionContext {
   // Dependency inject the actorsystem from elsewhere
   public MyCustomExecutionContext(ActorSystem actorSystem) {
     super(actorSystem, "full.path.to.my-custom-executor");
   }
 }
 
 

Then use your custom execution context where you have blocking operations that require processing outside of Play's main rendering thread.

See Also:

Dispatchers, Thread Pools

Nested Class Summary

Nested classes/interfaces inherited from interface scala.concurrent.ExecutionContext

scala.concurrent.ExecutionContext.Implicits$

Constructor Summary

Constructors

Constructor and Description
CustomExecutionContext(akka.actor.ActorSystem actorSystem, java.lang.String name)

Method Summary

Modifier and Type	Method and Description
void	execute(java.lang.Runnable command)
scala.concurrent.ExecutionContext	prepare()
void	reportFailure(java.lang.Throwable cause)

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomExecutionContext

public CustomExecutionContext(akka.actor.ActorSystem actorSystem,
                              java.lang.String name)

Method Detail

prepare

public scala.concurrent.ExecutionContext prepare()

Specified by:

prepare in interface scala.concurrent.ExecutionContext

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

Specified by:

execute in interface scala.concurrent.ExecutionContext

reportFailure

public void reportFailure(java.lang.Throwable cause)

Specified by:

reportFailure in interface scala.concurrent.ExecutionContext