当前位置: 首页 > 知识库问答 >
问题:

使用UUID命名时为akka执行元定义调度程序

拓拔辰钊
2023-03-14
akka.actor.deployment {
  "/actorName*" {
       dispatcher =  mycustom-dispatcher
  }
}

共有1个答案

董光霁
2023-03-14

是的,您可以显式地将调度程序分配给您的执行元[s]。

import akka.actor.Props
val myActor =
  context.actorOf(Props[MyActor].withDispatcher("my-dispatcher"), "myactor1")

java变体:

ActorRef myActor =
  system.actorOf(Props.create(MyUntypedActor.class).withDispatcher("my-dispatcher"),
    "myactor3");

带配置

my-dispatcher {
  executor = "thread-pool-executor"
  type = PinnedDispatcher
}
 类似资料:
  • 我有以下actor向WebService发送请求: 对此执行元的调用是验证方法的一部分,如果尝试与ws: 与以前一样,我将收到以下日志消息: [信息][07/20/2017 10:28:05.738][Application-Akka.Actor.Default-Dispatcher-5][Akka://Application/Deadletters]未传递从执行元[Akka://Applicat

  • 我有以下代码块调用两个请求略有延迟。 在actor1和actor2中,我调用了一个REST请求,该请求返回一个cookie和响应消息。我在这里的意图是延迟发送与actor2对应的REST请求。然而,我从日志中观察到,请求立即从两个参与者发送,只有响应处理(在两个未来之间)延迟10秒。这是Akka中调度器的预期行为吗?如果我想在上述情况下延迟两个参与者之间的请求启动,我可以使用线程。睡觉(我在某个地

  • 但没有。在应用程序中创建的dispatcher线程使我在优化dispatcher配置时束手无策。每次重新启动应用程序时,我都看到创建了不同数量的dispatcher线程(每次启动应用程序后,我都通过线程转储检查这一点)。 甚至线程数也不等于我在Parallelism-min中定义的线程数。由于这个低线程数,我的应用程序的处理速度非常慢。一查号码。通过下面的代码: GetRuntime().Avai

  • 问题内容: 根据我一直在阅读的定义: 线程基本上是并发(同时)运行的代码段 。 但是,如何在存在线程调度程序的情况下同时运行它们? 我读到,线程调度程序基本上是从线程池中随机选择一个线程在某个时刻运行。从中我得到一个确切的时间点,只有一个可运行线程真正处于运行状态(运行)。( 所有这些均来自SCJP Sun认证程序员学习指南 )有人可以澄清吗? 这些线程是否真正同时运行? 问题答案: 但是,如何在

  • 当我测试自定义调度程序,但我的POD状态仍然挂起。https://kubernetes.io/docs/tasks/administer-cluster/configure-multiple-schedulers/ 我做了一个新的自定义调度器和3个像k8s样例yaml的测试pods,但是,使用'default-scheduler'的pods工作得很好,但是使用'my-scheduler'的pods