class I2CPMessageQueueImpl extends I2CPMessageQueue
コンストラクタ | 説明 |
---|---|
I2CPMessageQueueImpl(java.util.concurrent.BlockingQueue<I2CPMessage> in,
java.util.concurrent.BlockingQueue<I2CPMessage> out) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
boolean |
offer(I2CPMessage msg) |
Send a message, nonblocking
|
boolean |
offer(I2CPMessage msg,
long timeout) |
Send a message, blocking.
|
I2CPMessage |
poll() |
Receive a message, nonblocking
|
void |
put(I2CPMessage msg) |
Send a message, blocking until space is available
|
I2CPMessage |
take() |
Receive a message, blocking until one is available
|
close
public I2CPMessageQueueImpl(java.util.concurrent.BlockingQueue<I2CPMessage> in, java.util.concurrent.BlockingQueue<I2CPMessage> out)
public boolean offer(I2CPMessage msg)
offer
クラス内 I2CPMessageQueue
public boolean offer(I2CPMessage msg, long timeout) throws java.lang.InterruptedException
offer
クラス内 I2CPMessageQueue
timeout
- how long to wait for space (ms)java.lang.InterruptedException
public I2CPMessage poll()
poll
クラス内 I2CPMessageQueue
public void put(I2CPMessage msg) throws java.lang.InterruptedException
put
クラス内 I2CPMessageQueue
java.lang.InterruptedException
public I2CPMessage take() throws java.lang.InterruptedException
take
クラス内 I2CPMessageQueue
java.lang.InterruptedException