如何将自定义执行器注入到播放应用程序中？

Question

 public class ServiceA{

     final Executor executionContext;

     @Inject
     public ServiceA(ActorSystem system) {
        this.executionContext = system.dispatchers().lookup("akka.actor.db-context");
 }

 public class ServiceA{

     final Executor executionContext;

     @Inject
     public ServiceA(Executor dbExecutionCtx) {
        this.executionContext = dbExecutionCtx;
 }

Answer 1

我使用一种模式，我可以在任何我想要的地方得到EC。我在一个单例中创建一个ActorSystem并将其注入到我的服务中。

我有一个与ActorSystems、Dispatchers和更多用于监控的设计。看看这个，看看你能不能把它整合起来。

因此，如果MyActorSystem被注入到您的类中，您可以从它访问EC。了解myDispatcher以及EC：

@Singleton
public class MyActorSystem implements IMyActorSystem{

    ActorSystem system;
    public MyActorSystem() {
        system = ActorSystem.create();

    }

    public ActorRef create() {
        final ActorRef actor = system.actorOf(
                Props.create(MyWorker.class).withDispatcher("my-disp")
        );
        return actor;
    }

    public void shutdown(){
        system.shutdown();
    }

    public ExecutionContextExecutor getDispatcher(){
        return system.dispatcher();
    }
    }

    public class MyDispatcher implements IMyDispatcher {

    MyActorSystem system;

    @Inject public MyDispatcher(MyActorSystem system) {
        this.system = system;
    }


    public CompletableFuture<Object> dispatch(final Object story) {
        List<CompletableFuture<Object>> futureList = new ArrayList<>();
        final ActorRef actor = system.create();
        final CompletableFuture<Object> completed = FutureConverter
                .fromScalaFuture(Patterns.ask(actor, story, 50000)).executeOn(system.getDispatcher())
                .thenApply(i -> (Object) i);
        return completed;
    }

    public ExecutionContextExecutor getDispatcher(){
        return system.getDispatcher();
    }
}