Class ProcessServiceLogReadScheduler

java.lang.Object
eu.cloudnetservice.node.impl.service.defaults.log.ProcessServiceLogReadScheduler
@Singleton public final class ProcessServiceLogReadScheduler extends Object

  • Field Details

    • LOG_READ_DELAY_MS

      private static final int LOG_READ_DELAY_MS

    • READ_WORKER_MAXIMUM

      private static final int READ_WORKER_MAXIMUM

    • READ_ACTIONS_PER_WORKER

      private static final int READ_ACTIONS_PER_WORKER

    • runningReaderActions

      private final AtomicInteger runningReaderActions

    • executor

      private final ScheduledThreadPoolExecutor executor

  • Constructor Details

    • ProcessServiceLogReadScheduler

      public ProcessServiceLogReadScheduler()

  • Method Details

    • schedule

      public void schedule(@NonNull @NonNull ProcessServiceLogCache logCache)

    • notifyLogCacheReadEnd

      private void notifyLogCacheReadEnd()

    • adjustWorkerCount

      private void adjustWorkerCount(int expectedWorkerCount)