class Any2AnyIntImpl extends java.lang.Object implements Any2AnyChannelInt, ChannelInternalsInt
Modifier and Type | Field and Description |
---|---|
private ChannelInternalsInt |
channel |
private Mutex |
readMutex
The mutex on which readers must synchronize
|
private java.lang.Object |
writeMonitor |
Constructor and Description |
---|
Any2AnyIntImpl(ChannelInternalsInt _channel) |
Modifier and Type | Method and Description |
---|---|
void |
endRead() |
SharedChannelInputInt |
in()
Returns the input channel end.
|
SharedChannelOutputInt |
out()
Returns the output channel end.
|
int |
read() |
boolean |
readerDisable() |
boolean |
readerEnable(Alternative alt) |
boolean |
readerPending() |
void |
readerPoison(int strength) |
int |
startRead() |
void |
write(int n) |
void |
writerPoison(int strength) |
private ChannelInternalsInt channel
private final Mutex readMutex
private final java.lang.Object writeMonitor
Any2AnyIntImpl(ChannelInternalsInt _channel)
public SharedChannelInputInt in()
Any2AnyChannelInt
in
in interface Any2AnyChannelInt
public SharedChannelOutputInt out()
Any2AnyChannelInt
out
in interface Any2AnyChannelInt
public void endRead()
endRead
in interface ChannelInternalsInt
public int read()
read
in interface ChannelInternalsInt
public boolean readerDisable()
readerDisable
in interface ChannelInternalsInt
public boolean readerEnable(Alternative alt)
readerEnable
in interface ChannelInternalsInt
public boolean readerPending()
readerPending
in interface ChannelInternalsInt
public void readerPoison(int strength)
readerPoison
in interface ChannelInternalsInt
public int startRead()
startRead
in interface ChannelInternalsInt
public void write(int n)
write
in interface ChannelInternalsInt
public void writerPoison(int strength)
writerPoison
in interface ChannelInternalsInt