Package org.jcsp.lang
Class One2AnyIntImpl
- java.lang.Object
-
- org.jcsp.lang.One2AnyIntImpl
-
- All Implemented Interfaces:
ChannelInternalsInt,One2AnyChannelInt
- Direct Known Subclasses:
BufferedOne2AnyChannelIntImpl,One2AnyChannelIntImpl,PoisonableBufferedOne2AnyChannelInt,PoisonableOne2AnyChannelIntImpl
class One2AnyIntImpl extends java.lang.Object implements One2AnyChannelInt, ChannelInternalsInt
-
-
Field Summary
Fields Modifier and Type Field Description private ChannelInternalsIntchannelprivate MutexreadMutexThe mutex on which readers must synchronize
-
Constructor Summary
Constructors Constructor Description One2AnyIntImpl(ChannelInternalsInt _channel)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidendRead()SharedChannelInputIntin()Returns the input end of the channel.ChannelOutputIntout()Returns the output end of the channel.intread()booleanreaderDisable()booleanreaderEnable(Alternative alt)booleanreaderPending()voidreaderPoison(int strength)intstartRead()voidwrite(int n)voidwriterPoison(int strength)
-
-
-
Field Detail
-
channel
private ChannelInternalsInt channel
-
readMutex
private final Mutex readMutex
The mutex on which readers must synchronize
-
-
Constructor Detail
-
One2AnyIntImpl
One2AnyIntImpl(ChannelInternalsInt _channel)
-
-
Method Detail
-
in
public SharedChannelInputInt in()
Description copied from interface:One2AnyChannelIntReturns the input end of the channel.- Specified by:
inin interfaceOne2AnyChannelInt
-
out
public ChannelOutputInt out()
Description copied from interface:One2AnyChannelIntReturns the output end of the channel.- Specified by:
outin interfaceOne2AnyChannelInt
-
endRead
public void endRead()
- Specified by:
endReadin interfaceChannelInternalsInt
-
read
public int read()
- Specified by:
readin interfaceChannelInternalsInt
-
readerDisable
public boolean readerDisable()
- Specified by:
readerDisablein interfaceChannelInternalsInt
-
readerEnable
public boolean readerEnable(Alternative alt)
- Specified by:
readerEnablein interfaceChannelInternalsInt
-
readerPending
public boolean readerPending()
- Specified by:
readerPendingin interfaceChannelInternalsInt
-
readerPoison
public void readerPoison(int strength)
- Specified by:
readerPoisonin interfaceChannelInternalsInt
-
startRead
public int startRead()
- Specified by:
startReadin interfaceChannelInternalsInt
-
write
public void write(int n)
- Specified by:
writein interfaceChannelInternalsInt
-
writerPoison
public void writerPoison(int strength)
- Specified by:
writerPoisonin interfaceChannelInternalsInt
-
-