Class One2AnyImpl<T>

java.lang.Object

org.jcsp.lang.One2AnyImpl<T>

All Implemented Interfaces:

ChannelInternals<T>, One2AnyChannel<T>

Direct Known Subclasses:

BufferedOne2AnyChannel, One2AnyChannelImpl, PoisonableBufferedOne2AnyChannel, PoisonableOne2AnyChannelImpl

class One2AnyImpl<T>
extends Object
implements One2AnyChannel<T>, ChannelInternals<T>

Field Summary

Fields

Modifier and Type	Field	Description
private ChannelInternals<T>	channel
private final Mutex	readMutex	The mutex on which readers must synchronize

Constructor Summary

Constructors

Constructor	Description
One2AnyImpl(ChannelInternals<T> _channel)

Method Summary

Modifier and Type	Method	Description
void	endRead()
SharedChannelInput<T>	in()	Returns the input end of the channel.
ChannelOutput<T>	out()	Returns the output end of the channel.
T	read()
boolean	readerDisable()
boolean	readerEnable(Alternative alt)
boolean	readerPending()
void	readerPoison(int strength)
T	startRead()
void	write(T obj)
void	writerPoison(int strength)

Methods inherited from class Object

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

Field Details

channel

private ChannelInternals<T> channel

readMutex

private final Mutex readMutex

The mutex on which readers must synchronize

Constructor Details

One2AnyImpl

One2AnyImpl(ChannelInternals<T> _channel)

Method Details

in

public SharedChannelInput<T> in()

Description copied from interface: One2AnyChannel

Returns the input end of the channel.

Specified by:

in in interface One2AnyChannel<T>

out

public ChannelOutput<T> out()

Description copied from interface: One2AnyChannel

Returns the output end of the channel.

Specified by:

out in interface One2AnyChannel<T>

endRead

public void endRead()

Specified by:

endRead in interface ChannelInternals<T>

read

public T read()

Specified by:

read in interface ChannelInternals<T>

readerDisable

public boolean readerDisable()

Specified by:

readerDisable in interface ChannelInternals<T>

readerEnable

public boolean readerEnable(Alternative alt)

Specified by:

readerEnable in interface ChannelInternals<T>

readerPending

public boolean readerPending()

Specified by:

readerPending in interface ChannelInternals<T>

readerPoison

public void readerPoison(int strength)

Specified by:

readerPoison in interface ChannelInternals<T>

startRead

public T startRead()

Specified by:

startRead in interface ChannelInternals<T>

write

public void write(T obj)

Specified by:

write in interface ChannelInternals<T>

writerPoison

public void writerPoison(int strength)

Specified by:

writerPoison in interface ChannelInternals<T>