Package io.deephaven.base.queue

Class ProducerConsumerWithTake<T>

java.lang.Object

io.deephaven.base.queue.ProducerConsumerWithTake<T>

All Implemented Interfaces:

ProducerConsumer<T>

public class ProducerConsumerWithTake<T>
extends Object
implements ProducerConsumer<T>

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.base.queue.ProducerConsumer

ProducerConsumer.MultiConsumer<T>, ProducerConsumer.MultiProducer<T>, ProducerConsumer.MultiProducerConsumer<T>, ProducerConsumer.SingleProducerConsumer<T>

Constructor Summary

Constructors

Constructor	Description
ProducerConsumerWithTake(ProducerConsumer<T> producerConsumer)

Method Summary

Modifier and Type	Method	Description
T	consume()	This method should never block (but it may spin for a finite amount of time) Returns null when there is nothing to consume [may create new objects on the fly if necessary]
boolean	produce(T t)	This method should never block (but it may spin for a finite amount of time) Returns true when t was successfully produced, else false
int	size()
T	take()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ProducerConsumerWithTake

public ProducerConsumerWithTake(ProducerConsumer<T> producerConsumer)

Method Details

produce

public boolean produce(T t)

Description copied from interface: ProducerConsumer

This method should never block (but it may spin for a finite amount of time) Returns true when t was successfully produced, else false

Specified by:

produce in interface ProducerConsumer<T>

consume

public T consume()

Description copied from interface: ProducerConsumer

This method should never block (but it may spin for a finite amount of time) Returns null when there is nothing to consume [may create new objects on the fly if necessary]

Specified by:

consume in interface ProducerConsumer<T>

take

public T take()

size

public int size()