See: Description
Interface | Description |
---|---|
Flow.Processor<T,R> |
A component that acts as both a Subscriber and Publisher.
|
Flow.Publisher<T> |
A producer of items (and related control messages) received by
Subscribers.
|
Flow.Subscriber<T> |
A receiver of messages.
|
Flow.Subscription |
Message control linking a
Flow.Publisher and Flow.Subscriber . |
Class | Description |
---|---|
Flow |
Interrelated interfaces and static methods for establishing
flow-controlled components in which
Publishers
produce items consumed by one or more Subscribers , each managed by a Subscription . |
SubmissionPublisher<T> |
A
Flow.Publisher that asynchronously issues submitted
(non-null) items to current subscribers until it is closed. |
SubmissionPublisher.BufferedSubscription<T> |
A bounded (ring) buffer with integrated control to start a
consumer task whenever items are available.
|
SubmissionPublisher.ConsumerSubscriber<T> |
Subscriber for method consume
|
SubmissionPublisher.ConsumerTask<T> |
A task for consuming buffer items and signals, created and
executed whenever they become available.
|
SubmissionPublisher.ThreadPerTaskExecutor |
Fallback if ForkJoinPool.commonPool() cannot support parallelism
|
UnsafeAccessor |
Helper for classes in the jsr166 package to access the
sun.misc.Unsafe instance. |