?? PushbackPolicy<T,U extends BlockingQueue<PushEvent<? extends T>>>
- ????:
T
- The type of the dataU
- 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.- ????:
-
????
-
??????
-
pushback
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
-