?? PushbackPolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>

????:
T - The type of the data
U - The type of the queue
????:
????????, ????? lambda ??????????????

@ConsumerType @FunctionalInterface public interface PushbackPolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>
A PushbackPolicy is used to calculate how much back pressure to apply based on the current buffer. The PushbackPolicy will be called after an event has been queued, and the returned value will be used as back pressure.
????:
  • ????

    ??????
    ??
    ??
    long
    pushback(U queue)
    Given the current state of the queue, determine the level of back pressure that should be applied
  • ??????

    • pushback

      long pushback(U queue) throws Exception
      Given the current state of the queue, determine the level of back pressure that should be applied
      ??:
      queue -
      ??:
      a back pressure value in nanoseconds
      ??:
      Exception