public class PriorityThreadsDispatcher
extends akka.dispatch.DispatcherConfigurator
Example of configuration:
low-priority-threads-dispatcher { type = org.apache.flink.runtime.rpc.akka.PriorityThreadsDispatcher executor = "thread-pool-executor" # should be between Thread.MIN_PRIORITY (which is 1) and Thread.MAX_PRIORITY (which is 10) threads-priority = 1 thread-pool-executor { core-pool-size-min = 0 core-pool-size-factor = 2.0 core-pool-size-max = 10 } }
Two arguments constructor (the primary constructor) is automatically called by Akka when it finds:
abcde-dispatcher { type = org.apache.flink.runtime.rpc.akka.PriorityThreadsDispatcher <-- the class that Akka will instantiate ... }
Constructor and Description |
---|
PriorityThreadsDispatcher(com.typesafe.config.Config config,
akka.dispatch.DispatcherPrerequisites prerequisites) |
public PriorityThreadsDispatcher(com.typesafe.config.Config config, akka.dispatch.DispatcherPrerequisites prerequisites)
config
- passed automatically by Akka, should contain information about threads priorityprerequisites
- passed automatically by AkkaCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.