I2CPMessageQueue (I2P Anonymous Network - Java Documentation

java.lang.Object
- net.i2p.internal.I2CPMessageQueue

すべての実装されたインタフェース:

java.io.Closeable, java.lang.AutoCloseable

直系の既知のサブクラス:

I2CPMessageQueueImpl
```
public abstract class I2CPMessageQueue
extends java.lang.Object
implements java.io.Closeable
```
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().

導入されたバージョン:

0.8.3

作成者:

zzz

コンストラクタの概要

コンストラクタ
コンストラクタ説明

I2CPMessageQueue()

コンストラクタ
コンストラクタ	説明
`I2CPMessageQueue()`

メソッドの概要

すべてのメソッドインスタンス・メソッド abstractメソッド concreteメソッド
修飾子とタイプ	メソッド	説明
`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.

クラスから継承されたメソッド java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- コンストラクタの詳細
  - I2CPMessageQueue
```
public I2CPMessageQueue()
```
- メソッドの詳細
  - offer
```
public abstract boolean offer(I2CPMessage msg)
```
    Send a message, nonblocking.
    
    戻り値:
    
    success (false if no space available)
  - offer
```
public abstract boolean offer(I2CPMessage msg,
                              long timeout)
                       throws java.lang.InterruptedException
```
    Send a message, blocking.
    
    パラメータ:
    
    timeout - how long to wait for space (ms)
    
    戻り値:
    
    success (false if no space available or if timed out)
    
    例外:
    
    java.lang.InterruptedException
    
    導入されたバージョン:
    
    0.9.3
  - poll
```
public abstract I2CPMessage poll()
```
    Receive a message, nonblocking. Unused for now.
    
    戻り値:
    
    message or null if none available
  - put
```
public abstract void put(I2CPMessage msg)
                  throws java.lang.InterruptedException
```
    Send a message, blocking until space is available. Unused for now.
    
    例外:
    
    java.lang.InterruptedException
  - take
```
public abstract I2CPMessage take()
                          throws java.lang.InterruptedException
```
    Receive a message, blocking until one is available.
    
    戻り値:
    
    message
    
    例外:
    
    java.lang.InterruptedException
  - close
```
public void close()
```
    == offer(new PoisonI2CPMessage());
    
    定義:
    
    close インタフェース内 java.lang.AutoCloseable
    
    定義:
    
    close インタフェース内 java.io.Closeable

クラス I2CPMessageQueue

コンストラクタの概要

メソッドの概要

クラスから継承されたメソッド java.lang.Object

コンストラクタの詳細

I2CPMessageQueue

メソッドの詳細

offer

offer

poll

put

take

close