| Package | Description |
|---|---|
| org.jctools.queues.alt |
| Modifier and Type | Method and Description |
|---|---|
int |
Consumer.consume(ConsumerFunction<E> c,
int batch) |
int |
ConcurrentQueueConsumer.consume(ConsumerFunction<E> consumer,
int batchSize)
As many elements as are visible are delivered to the
Consumer. |
int |
ConcurrentQueueFactory.GenericQueue.consume(ConsumerFunction<E> consumer,
int batchSize) |
int |
MpscArrayConcurrentQueueColdFields.Consumer.consume(ConsumerFunction<E> consumer,
int batchSize) |
int |
MpmcArrayConcurrentQueueColdFields.Consumer.consume(ConsumerFunction<E> consumer,
int batchSize) |