Package co.paralleluniverse.strands.channels

Class QueueObjectChannel<Message>

java.lang.Object

co.paralleluniverse.strands.channels.QueueChannel<Message>

co.paralleluniverse.strands.channels.QueueObjectChannel<Message>

All Implemented Interfaces:

Channel<Message>, Port<Message>, PortAutoCloseable, ReceivePort<Message>, Selectable<Message>, SendPort<Message>, StandardChannel<Message>, Synchronization, java.io.Serializable, java.lang.AutoCloseable

public class QueueObjectChannel<Message>
extends QueueChannel<Message>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface co.paralleluniverse.strands.channels.ReceivePort

ReceivePort.EOFException

Field Summary

Fields inherited from class co.paralleluniverse.strands.channels.QueueChannel

RECORDER

Constructor Summary

Constructors

Constructor	Description
QueueObjectChannel(co.paralleluniverse.strands.queues.BasicQueue<Message> queue, Channels.OverflowPolicy policy, boolean singleProducer, boolean singleConsumer)

Method Summary

Methods inherited from class co.paralleluniverse.strands.channels.QueueChannel

capacity, close, close, equals, getCloseException, getOverflowPolicy, getQueueLength, isClosed, isSingleConsumer, isSingleProducer, receive, receive, receive, receiveFromThread, receiveFromThread, register, register, send, send, send, send0, sendNonSuspendable, sendSync, signalAndWait, signalReceivers, sync, toString, tryNow, tryReceive, trySend, unregister, writeReplace

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueObjectChannel

public QueueObjectChannel(co.paralleluniverse.strands.queues.BasicQueue<Message> queue,
                          Channels.OverflowPolicy policy,
                          boolean singleProducer,
                          boolean singleConsumer)