Package rx.internal.producers
Class QueuedValueProducer<T>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicLong
-
- rx.internal.producers.QueuedValueProducer<T>
-
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
java.io.Serializable
,Producer
public final class QueuedValueProducer<T> extends java.util.concurrent.atomic.AtomicLong implements Producer
Producer that holds an unbounded (or custom) queue to enqueue values and relays them to a child subscriber on request.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description (package private) Subscriber<? super T>
child
(package private) static java.lang.Object
NULL_SENTINEL
(package private) java.util.Queue<java.lang.Object>
queue
private static long
serialVersionUID
(package private) java.util.concurrent.atomic.AtomicInteger
wip
-
Constructor Summary
Constructors Constructor Description QueuedValueProducer(Subscriber<? super T> child)
Constructs an instance with the target child subscriber and an Spsc Linked (Atomic) Queue as the queue implementation.QueuedValueProducer(Subscriber<? super T> child, java.util.Queue<java.lang.Object> queue)
Constructs an instance with the target child subscriber and a custom queue implementation
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
drain()
boolean
offer(T value)
Offers a value to this producer and tries to emit any queued values if the child requests allow it.void
request(long n)
Request a certain maximum number of items from this Producer.-
Methods inherited from class java.util.concurrent.atomic.AtomicLong
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
child
final Subscriber<? super T> child
-
queue
final java.util.Queue<java.lang.Object> queue
-
wip
final java.util.concurrent.atomic.AtomicInteger wip
-
NULL_SENTINEL
static final java.lang.Object NULL_SENTINEL
-
-
Constructor Detail
-
QueuedValueProducer
public QueuedValueProducer(Subscriber<? super T> child)
Constructs an instance with the target child subscriber and an Spsc Linked (Atomic) Queue as the queue implementation.- Parameters:
child
- the target child subscriber
-
QueuedValueProducer
public QueuedValueProducer(Subscriber<? super T> child, java.util.Queue<java.lang.Object> queue)
Constructs an instance with the target child subscriber and a custom queue implementation- Parameters:
child
- the target child subscriberqueue
- the queue to use
-
-
Method Detail
-
request
public void request(long n)
Description copied from interface:Producer
Request a certain maximum number of items from this Producer. This is a way of requesting backpressure. To disable backpressure, passLong.MAX_VALUE
to this method.Requests are additive but if a sequence of requests totals more than
Long.MAX_VALUE
thenLong.MAX_VALUE
requests will be actioned and the extras may be ignored. Arriving atLong.MAX_VALUE
by addition of requests cannot be assumed to disable backpressure. For example, the code below may result inLong.MAX_VALUE
requests being actioned only.request(100); request(Long.MAX_VALUE-1);
-
offer
public boolean offer(T value)
Offers a value to this producer and tries to emit any queued values if the child requests allow it.- Parameters:
value
- the value to enqueue and attempt to drain- Returns:
- true if the queue accepted the offer, false otherwise
-
drain
private void drain()
-
-