Package net.i2p.internal
Class I2CPMessageQueue
java.lang.Object
net.i2p.internal.I2CPMessageQueue
- All Implemented Interfaces:
Closeable
,AutoCloseable
- Direct Known Subclasses:
I2CPMessageQueueImpl
Contains the methods to talk to a router or client via I2CP,
when both are in the same JVM.
This interface contains methods to access two queues,
one for transmission and one for receiving.
The methods are identical to those in java.util.concurrent.BlockingQueue.
Reading may be done in a thread using the QueuedI2CPMessageReader class.
Non-blocking writing may be done directly with offer().
- Since:
- 0.8.3
- Author:
- zzz
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
== offer(new PoisonI2CPMessage());abstract boolean
offer
(I2CPMessage msg) Send a message, nonblocking.abstract boolean
offer
(I2CPMessage msg, long timeout) Send a message, blocking.abstract I2CPMessage
poll()
Receive a message, nonblocking.abstract void
put
(I2CPMessage msg) Send a message, blocking until space is available.abstract I2CPMessage
take()
Receive a message, blocking until one is available.
-
Constructor Details
-
I2CPMessageQueue
public I2CPMessageQueue()
-
-
Method Details
-
offer
Send a message, nonblocking.- Returns:
- success (false if no space available)
-
offer
Send a message, blocking.- Parameters:
timeout
- how long to wait for space (ms)- Returns:
- success (false if no space available or if timed out)
- Throws:
InterruptedException
- Since:
- 0.9.3
-
poll
Receive a message, nonblocking. Unused for now.- Returns:
- message or null if none available
-
put
Send a message, blocking until space is available. Unused for now.- Throws:
InterruptedException
-
take
Receive a message, blocking until one is available.- Returns:
- message
- Throws:
InterruptedException
-
close
public void close()== offer(new PoisonI2CPMessage());- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
-