我正在使用Play 2.1和Scala来连续运行几个测试。我正在做一个Future.traverse(tests)(test => Future(runTest(test))。
我想限制并行运行的测试数量,因此我想限制默认分派程序中的线程数量。
我试着把
play {
akka {
event-handlers = ["akka.event.slf4j.Slf4jEventHandler"]
loglevel = WARNING
actor {
default-dispatcher = {
fork-join-executor {
parallelism-factor = 1.0
parallelism-max = 2
}
}
}
}
} 在application.conf中,但它似乎没有任何影响(当我运行程序时,每个内核仍然有一个线程)。对于其他播放设置,可以正确读取application.conf。
我试图摆脱围绕它的游戏{},但它什么也改变不了。
我尝试了不同的执行上下文导入,但都没有成功:
//import scala.concurrent.ExecutionContext.Implicits._
import play.api.libs.concurrent.Execution.Implicits._当我运行应用程序时,我收到以下消息,因此它似乎是使用的默认调度程序:
[info] play - Starting application default Akka system.有人知道为什么我不能配置默认调度程序吗?
谢谢!
线程列表:
main
Reference Handler
Finalizer
Signal Dispatcher
FSEvent thread
Attach Listener
play-scheduler-1
Timer-0
com.google.common.base.internal.Finalizer
BoneCP-keep-alive-scheduler
BoneCP-max-alive-scheduler
BoneCP-pool-alive-scheduler
application-akka.actor.default-dispatcher-2
application-scheduler-1
ForkJoinPool-3-worker-1
default-scheduler-1
default-scheduler-1
default-scheduler-1
default-akka.actor.default-dispatcher-3
default-akka.actor.default-dispatcher-5
default-akka.actor.default-dispatcher-3
default-akka.actor.default-dispatcher-2
default-akka.actor.default-dispatcher-5
default-pinned-dispatcher-4
play-akka.actor.default-dispatcher-2
play-akka.actor.default-dispatcher-4
Timer-1
Timer-3
Timer-4
Hashed wheel timer #1
Hashed wheel timer #2
Hashed wheel timer #3
AsyncHttpClient-Reaper
AsyncHttpClient-Reaper
AsyncHttpClient-Reaper
default-pinned-dispatcher-4
default-pinned-dispatcher-4
New I/O boss #35
New I/O boss #44和8 play-internal-execution-context- (1到8)
和8 iteratee-execution-context- (1到8)
和62 New I/O worker # (1到62)
发布于 2013-06-24 15:34:32
您忘记的设置是parallelism-min,它默认为8。但是在您更改该设置之前,请考虑不要使用默认的dispatcher :将其限制为两个线程很可能会破坏系统。我建议您在将来使用configuring a specific dispatcher。
https://stackoverflow.com/questions/17191546
复制相似问题