|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.ObjectEDU.oswego.cs.dl.util.concurrent.SemaphoreControlledChannel
EDU.oswego.cs.dl.util.concurrent.misc.PipedChannel
A channel based on a java.io.PipedInputStream and java.io.PipedOutputStream. Elements are serialized using ObjectInputStreams and ObjectOutputStreams upon insertion and extraction from the pipe.
IO Exceptions are transformed into Errors. This is in general not a good idea, but seems to be the most reasonable compromise for the intended usage contexts.
Status Uncertain. There are enough conceptual and implementation snags surrounding use of pipes as Channels to downplay use. However, without such bridges, people would have to duplicate code that should work the same way in both cases.
[ Introduction to this package. ]
Field Summary | |
protected ObjectInputStream |
in_
|
protected PipedInputStream |
inp_
|
protected ObjectOutputStream |
out_
|
protected PipedOutputStream |
outp_
|
Fields inherited from class EDU.oswego.cs.dl.util.concurrent.SemaphoreControlledChannel |
capacity_, putGuard_, takeGuard_ |
Constructor Summary | |
PipedChannel()
|
Method Summary | |
protected Object |
extract()
Shared mechanics for take-based methods |
protected ObjectInputStream |
in()
Return input stream, first constructing if necessary. |
protected void |
insert(Object x)
Shared mechanics for put-based methods |
protected ObjectOutputStream |
out()
Return output stream, first constructing if necessary. |
Object |
peek()
Stubbed out for now |
Methods inherited from class EDU.oswego.cs.dl.util.concurrent.SemaphoreControlledChannel |
capacity, offer, poll, put, size, take |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected ObjectInputStream in_
protected ObjectOutputStream out_
protected final PipedOutputStream outp_
protected final PipedInputStream inp_
Constructor Detail |
public PipedChannel()
Method Detail |
protected ObjectInputStream in()
protected ObjectOutputStream out()
protected void insert(Object x)
insert
in class SemaphoreControlledChannel
protected Object extract()
extract
in class SemaphoreControlledChannel
public Object peek()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |