java.io.Closeable
, java.lang.AutoCloseable
I2CPMessageQueueImpl
public abstract class I2CPMessageQueue
extends java.lang.Object
implements java.io.Closeable
コンストラクタ | 説明 |
---|---|
I2CPMessageQueue() |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
void |
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.
|
public abstract boolean offer(I2CPMessage msg)
public abstract boolean offer(I2CPMessage msg, long timeout) throws java.lang.InterruptedException
timeout
- how long to wait for space (ms)java.lang.InterruptedException
public abstract I2CPMessage poll()
public abstract void put(I2CPMessage msg) throws java.lang.InterruptedException
java.lang.InterruptedException
public abstract I2CPMessage take() throws java.lang.InterruptedException
java.lang.InterruptedException
public void close()
close
インタフェース内 java.lang.AutoCloseable
close
インタフェース内 java.io.Closeable