Class NormalPriorityExecutor

  • All Implemented Interfaces:

    
    public final class NormalPriorityExecutor
    extends PingExecutor
                        

    Executor for handling normal priority pings.

    Processes normal pings with a fixed concurrency cap (N = com.inmobi.media.core.config.models.AdConfig maxBatchSize.normal) via runSlots. The network gate lives inside the nextBatch lambda:

    When processing ends with pings still in the DB, it schedules itself after the configured interval so retries fire as they become eligible; when the DB is empty it stops. A new ping wakes a sleeping re-run immediately.

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
    • Field Summary

      Fields 
      Modifier and Type Field Description
    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description
    • Method Summary

      Modifier and Type Method Description
      final Unit handleResult(PingExecutor.PingResult result)
      final Unit setStarted(Boolean started)
      • Methods inherited from class com.inmobi.media.pingsv2.executor.PingExecutor

        isStarted, isStopped, onNewPing, setState, start, stop
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait