TP.TransferQueueBundler

所有类

概要:
嵌套 |
字段 |
构造器 |
方法

详细资料:
字段 |
构造器 |
方法

java.lang.Object
- com.fr.third.jgroups.protocols.TP.BaseBundler
- - com.fr.third.jgroups.protocols.TP.TransferQueueBundler

所有已实现的接口:

TP.Bundler, java.lang.Runnable

封闭类:

TP
```
protected class TP.TransferQueueBundler
extends TP.BaseBundler
implements java.lang.Runnable
```
This bundler adds all (unicast or multicast) messages to a queue until max size has been exceeded, but does send messages immediately when no other messages are available. https://issues.jboss.org/browse/JGRP-1540

字段概要

字段
限定符和类型	字段和说明
`protected java.lang.Thread`	`bundler_thread`
`protected java.util.concurrent.BlockingQueue<Message>`	`queue`
`protected static java.lang.String`	`THREAD_NAME`
`protected int`	`threshold`

构造器概要

构造器
限定符构造器和说明

protected TP.TransferQueueBundler(int capacity)

方法概要

方法
限定符和类型方法和说明

int getBufferSize()

java.lang.Thread getThread()

void run()

void send(Message msg)

void start()

void stop()
- 从类继承的方法 com.fr.third.jgroups.protocols.TP.BaseBundler
  addMessage, checkLength, numMessages, sendBundledMessages, sendMessageList, sendSingleMessage
- 从类继承的方法 java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - threshold
```
protected final int threshold
```
  - queue
```
protected final java.util.concurrent.BlockingQueue<Message> queue
```
  - bundler_thread
```
protected volatile java.lang.Thread bundler_thread
```
  - THREAD_NAME
```
protected static final java.lang.String THREAD_NAME
```
    另请参阅:
    常量字段值
- 构造器详细资料
  - TP.TransferQueueBundler
```
protected TP.TransferQueueBundler(int capacity)
```
- 方法详细资料
  - getThread
```
public java.lang.Thread getThread()
```
  - getBufferSize
```
public int getBufferSize()
```
  - start
```
public void start()
```
    指定者:
    
    start 在接口中 TP.Bundler
    
    覆盖:
    
    start 在类中 TP.BaseBundler
  - stop
```
public void stop()
```
    指定者:
    
    stop 在接口中 TP.Bundler
    
    覆盖:
    
    stop 在类中 TP.BaseBundler
  - send
```
public void send(Message msg)
          throws java.lang.Exception
```
    指定者:
    
    send 在接口中 TP.Bundler
    
    覆盖:
    
    send 在类中 TP.BaseBundler
    
    抛出:
    
    java.lang.Exception
  - run
```
public void run()
```
    指定者:
    
    run 在接口中 java.lang.Runnable

所有类

概要:
嵌套 |
字段 |
构造器 |
方法

详细资料:
字段 |
构造器 |
方法