Class TransportPoller

java.lang.Object
org.agrona.nio.TransportPoller
All Implemented Interfaces:
AutoCloseable

public class TransportPoller extends Object implements AutoCloseable
Implements the common functionality for a transport poller.
  • Field Details

    • ITERATION_THRESHOLD_PROP_NAME

      public static final String ITERATION_THRESHOLD_PROP_NAME
      System property name for the threshold beyond which individual channel/socket polling will swap to using a Selector.
      See Also:
    • ITERATION_THRESHOLD_DEFAULT

      public static final int ITERATION_THRESHOLD_DEFAULT
      Default threshold beyond which individual channel/socket polling will swap to using a Selector.
      See Also:
    • ITERATION_THRESHOLD

      public static final int ITERATION_THRESHOLD
      Threshold beyond which individual channel/socket polling will swap to using a Selector.
      See Also:
    • selector

      protected final Selector selector
      Reference to the Selector for the transport.
  • Constructor Details

    • TransportPoller

      public TransportPoller()
      Default constructor.
  • Method Details

    • close

      public void close()
      Close NioSelector down. Returns immediately.
      Specified by:
      close in interface AutoCloseable
    • selectNowWithoutProcessing

      public void selectNowWithoutProcessing()
      Explicit call to Selector.selectNow() followed by clearing out the set without processing.