com.wantedtech.common.xpresso.experimental.concurrency

Class Channel<T>

java.lang.Object

com.wantedtech.common.xpresso.experimental.concurrency.Channel<T>

All Implemented Interfaces:

java.lang.Iterable<T>

Direct Known Subclasses:

ReceiveOnlyChannel, SendOnlyChannel

public class Channel<T>
extends java.lang.Object
implements java.lang.Iterable<T>

Constructor Summary

Constructors

Constructor and Description
Channel(java.lang.Class<T> type)
Channel(java.lang.Class<T> type, int bufferSize)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getBufferSize()
java.lang.Class<T>	getType()
boolean	isClosed()
java.util.Iterator<T>	iterator()
T	receive()
ReceiveOnlyChannel<T>	receiveOnly()
void	registerGoer(Goer<T> g)
void	send(T value)
SendOnlyChannel<T>	sendOnly()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

Channel

public Channel(java.lang.Class<T> type)

Channel

public Channel(java.lang.Class<T> type,
               int bufferSize)

Method Detail

getType

public java.lang.Class<T> getType()

getBufferSize

public int getBufferSize()

receiveOnly

public ReceiveOnlyChannel<T> receiveOnly()

sendOnly

public SendOnlyChannel<T> sendOnly()

send

public void send(T value)

receive

public T receive()

registerGoer

public void registerGoer(Goer<T> g)

close

public void close()

isClosed

public boolean isClosed()

iterator

public java.util.Iterator<T> iterator()

Specified by:

iterator in interface java.lang.Iterable<T>