Class WorkerFamilyManager


  • public class WorkerFamilyManager
    extends java.lang.Object
    • Constructor Detail

      • WorkerFamilyManager

        public WorkerFamilyManager​(java.lang.String family,
                                   int queueSize)
    • Method Detail

      • registerWorker

        public void registerWorker​(WorkerBean workerBean)
      • unregisterWorker

        public void unregisterWorker​(java.lang.String workerId)
        Parameters:
        workerId - the id of worker to unregister
      • getExecutor

        public java.util.concurrent.Executor getExecutor​(boolean isHighPriorityTask)
      • getWorkers

        public java.util.Map<java.lang.String,​WorkerExecutor> getWorkers()
      • getFamily

        public java.lang.String getFamily()