public class PriorityThreadsDispatcher
extends org.apache.pekko.dispatch.DispatcherConfigurator
Example of configuration:
low-priority-threads-dispatcher { type = org.apache.flink.runtime.rpc.pekko.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 Pekko when it finds:
abcde-dispatcher { type = org.apache.flink.runtime.rpc.pekko.PriorityThreadsDispatcher <-- the class that Pekko will instantiate ... }
Constructor and Description |
---|
PriorityThreadsDispatcher(com.typesafe.config.Config config,
org.apache.pekko.dispatch.DispatcherPrerequisites prerequisites) |
public PriorityThreadsDispatcher(com.typesafe.config.Config config, org.apache.pekko.dispatch.DispatcherPrerequisites prerequisites)
config
- passed automatically by Pekko, should contain information about threads
priorityprerequisites
- passed automatically by PekkoCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.