Package org.apache.flink.runtime.rpc.pekko

Class PriorityThreadsDispatcher

  • public class PriorityThreadsDispatcher
extends org.apache.pekko.dispatch.DispatcherConfigurator
    Pekko dispatcher threads creates threads with configurable priority.

    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 Summary

      Constructors 
      Constructor Description
      PriorityThreadsDispatcher​(com.typesafe.config.Config config, org.apache.pekko.dispatch.DispatcherPrerequisites prerequisites)  

    • Constructor Detail

      • PriorityThreadsDispatcher

        public PriorityThreadsDispatcher​(com.typesafe.config.Config config,
                                 org.apache.pekko.dispatch.DispatcherPrerequisites prerequisites)
        Parameters:
        config - passed automatically by Pekko, should contain information about threads priority
        prerequisites - passed automatically by Pekko