DelayFlusher (weforward-data-api 1.2.2 API)

java.lang.Object
- cn.weforward.data.util.DelayFlusher

所有已实现的接口:

cn.weforward.common.Destroyable, cn.weforward.common.DestroyableExt, Flusher
```
public class DelayFlusher
extends Object
implements Flusher, cn.weforward.common.DestroyableExt
```
延时及周期执行刷写动作的刷写器

作者:

liangyi

字段概要

字段
限定符和类型	字段和说明
`static org.slf4j.Logger`	`_Logger` 日志记录器
`protected static int`	`BUSY_DELAY` 正在执行延时刷写
`protected static int`	`BUSY_FAIL` 正在执行失败重试刷写
`protected static int`	`BUSY_MASK_COUNT` 标识数量的位
`protected static int`	`BUSY_MASK_STATE` 标识忙的位
`protected static int`	`BUSY_PERIOD` 正在执行周期刷写
`protected static int`	`BUSY_REINDEX` 正在执行重索引
`protected int`	`m_Busy` 是否正在刷写或处理中（只是作简单标识，操作非原子）
`protected cn.weforward.common.util.SinglyLinked<Flushable>`	`m_DelayList` 延时刷写项链表
`protected cn.weforward.common.util.SinglyLinked<Flushable>`	`m_FailList` 延时刷写出错项链表
`protected int`	`m_FlushInterval` 每次后台刷写的最小间隔（毫秒）
`protected cn.weforward.common.util.SinglyLinked.SinglyLinkedNode<Flushable>`	`m_FlushPending` 执行刷写中的表
`protected int`	`m_FlushPeriod` 刷写周期（毫秒）
`protected long`	`m_LastDelayFlush` 最后延时刷写时间戳
`protected long`	`m_LastPeriodFlush` 最后周期刷写时间戳
`protected ReentrantLock`	`m_Lock` 锁
`protected int`	`m_MaxSuspend` 最多等待刷写的累积项数（0表示不控制）
`protected String`	`m_Name` 名称
`protected int`	`m_State` 状态 STATE_xxx
`protected Thread`	`m_ThreadFlush` 刷写的后台工作线程
`protected Condition`	`m_WaitWriteTask` 等待刷写任务条件
`protected static int`	`STATE_CLOSED` 刷写器已关闭
`protected static int`	`STATE_FLUSH_CLOSED` 刷写线程已关闭
`protected static int`	`STATE_FLUSH_STARTING` 刷写线程启动中
`protected static int`	`STATE_PERIOD` 执行周期刷写
`protected static int`	`STATE_REINDEX_CLOSED` 重索引线程已关闭
`protected static int`	`STATE_STOP` 停止刷写器任务

构造器概要

构造器
构造器和说明

DelayFlusher()
构造刷写器，5秒延时

DelayFlusher(int interval)
构造刷写器

构造器
构造器和说明
`DelayFlusher()` 构造刷写器，5秒延时
`DelayFlusher(int interval)` 构造刷写器

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`void`	`close()` 关闭刷写器
`void`	`daemonFlushing()` 执行刷写任务
`void`	`destroy()`
`boolean`	`destroySignal()`
`protected void`	`finalize()`
`void`	`flush()` 立刻刷写所有待刷写的项
`void`	`flush(Flushable flushable)` 刷写待刷写项
`boolean`	`flushing()` 执行延时队列的刷写
`cn.weforward.common.util.SinglyLinked.SinglyLinkedNode<Flushable>`	`getFlushPending()` 执行刷写中的表
`int`	`getMaxSuspend()`
`String`	`getName()`
`void`	`mark(Flushable flushing)` 标记待刷写项
`protected void`	`markOnFail(Flushable flushing)` 标记刷写出错项
`void`	`setMaxSuspend(int limit)` 最多等待刷写的累积项数
`void`	`setName(String name)`
`String`	`toString()`
`boolean`	`tryFailFlushing()` 重试刷写错误的项

从类继承的方法 java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

- 字段详细资料
  - _Logger
```
public static final org.slf4j.Logger _Logger
```
    日志记录器
  - STATE_FLUSH_CLOSED
```
protected static final int STATE_FLUSH_CLOSED
```
    刷写线程已关闭
    
    另请参阅:
    
    常量字段值
  - STATE_REINDEX_CLOSED
```
protected static final int STATE_REINDEX_CLOSED
```
    重索引线程已关闭
    
    另请参阅:
    
    常量字段值
  - STATE_CLOSED
```
protected static final int STATE_CLOSED
```
    刷写器已关闭
    
    另请参阅:
    
    常量字段值
  - STATE_STOP
```
protected static final int STATE_STOP
```
    停止刷写器任务
    
    另请参阅:
    
    常量字段值
  - STATE_FLUSH_STARTING
```
protected static final int STATE_FLUSH_STARTING
```
    刷写线程启动中
    
    另请参阅:
    
    常量字段值
  - STATE_PERIOD
```
protected static final int STATE_PERIOD
```
    执行周期刷写
    
    另请参阅:
    
    常量字段值
  - BUSY_PERIOD
```
protected static final int BUSY_PERIOD
```
    正在执行周期刷写
    
    另请参阅:
    
    常量字段值
  - BUSY_DELAY
```
protected static final int BUSY_DELAY
```
    正在执行延时刷写
    
    另请参阅:
    
    常量字段值
  - BUSY_REINDEX
```
protected static final int BUSY_REINDEX
```
    正在执行重索引
    
    另请参阅:
    
    常量字段值
  - BUSY_FAIL
```
protected static final int BUSY_FAIL
```
    正在执行失败重试刷写
    
    另请参阅:
    
    常量字段值
  - BUSY_MASK_STATE
```
protected static final int BUSY_MASK_STATE
```
    标识忙的位
    
    另请参阅:
    
    常量字段值
  - BUSY_MASK_COUNT
```
protected static final int BUSY_MASK_COUNT
```
    标识数量的位
    
    另请参阅:
    
    常量字段值
  - m_Name
```
protected String m_Name
```
    名称
  - m_DelayList
```
protected final cn.weforward.common.util.SinglyLinked<Flushable> m_DelayList
```
    延时刷写项链表
  - m_FailList
```
protected final cn.weforward.common.util.SinglyLinked<Flushable> m_FailList
```
    延时刷写出错项链表
  - m_Lock
```
protected final ReentrantLock m_Lock
```
    锁
  - m_WaitWriteTask
```
protected final Condition m_WaitWriteTask
```
    等待刷写任务条件
  - m_FlushInterval
```
protected final int m_FlushInterval
```
    每次后台刷写的最小间隔（毫秒）
  - m_MaxSuspend
```
protected int m_MaxSuspend
```
    最多等待刷写的累积项数（0表示不控制）
  - m_State
```
protected volatile int m_State
```
    状态 STATE_xxx
  - m_LastDelayFlush
```
protected volatile long m_LastDelayFlush
```
    最后延时刷写时间戳
  - m_ThreadFlush
```
protected Thread m_ThreadFlush
```
    刷写的后台工作线程
  - m_Busy
```
protected volatile int m_Busy
```
    是否正在刷写或处理中（只是作简单标识，操作非原子）
  - m_FlushPending
```
protected cn.weforward.common.util.SinglyLinked.SinglyLinkedNode<Flushable> m_FlushPending
```
    执行刷写中的表
  - m_FlushPeriod
```
protected final int m_FlushPeriod
```
    刷写周期（毫秒）
  - m_LastPeriodFlush
```
protected volatile long m_LastPeriodFlush
```
    最后周期刷写时间戳
- 构造器详细资料
  - DelayFlusher
```
public DelayFlusher()
```
    构造刷写器，5秒延时
  - DelayFlusher
```
public DelayFlusher(int interval)
```
    构造刷写器
    
    参数:
    
    interval - 后台刷写的最小间隔（秒）
- 方法详细资料
  - setName
```
public void setName(String name)
```
  - getName
```
public String getName()
```
  - setMaxSuspend
```
public void setMaxSuspend(int limit)
```
    最多等待刷写的累积项数
    
    参数:
    
    limit - 要控制的项数，0表示不控制
  - getMaxSuspend
```
public int getMaxSuspend()
```
  - markOnFail
```
protected void markOnFail(Flushable flushing)
```
    标记刷写出错项
    
    参数:
    
    flushing - 待刷写项
  - mark
```
public void mark(Flushable flushing)
```
    从接口复制的说明: Flusher
    
    标记待刷写项
    
    指定者:
    
    mark 在接口中 Flusher
    
    参数:
    
    flushing - 待刷写项
  - flush
```
public void flush(Flushable flushable)
```
    从接口复制的说明: Flusher
    
    刷写待刷写项
    
    指定者:
    
    flush 在接口中 Flusher
    
    参数:
    
    flushable - 待刷写项
  - flush
```
public void flush()
```
    从接口复制的说明: Flusher
    
    立刻刷写所有待刷写的项
    
    指定者:
    
    flush 在接口中 Flusher
  - destroySignal
```
public boolean destroySignal()
```
    指定者:
    
    destroySignal 在接口中 cn.weforward.common.DestroyableExt
  - destroy
```
public void destroy()
```
    指定者:
    
    destroy 在接口中 cn.weforward.common.Destroyable
  - close
```
public void close()
```
    关闭刷写器
  - finalize
```
protected void finalize()
                 throws Throwable
```
    覆盖:
    
    finalize 在类中 Object
    
    抛出:
    
    Throwable
  - flushing
```
public boolean flushing()
```
    执行延时队列的刷写
    
    返回:
    
    是否刷写中
  - getFlushPending
```
public cn.weforward.common.util.SinglyLinked.SinglyLinkedNode<Flushable> getFlushPending()
```
    执行刷写中的表
    
    返回:
    
    链表
  - tryFailFlushing
```
public boolean tryFailFlushing()
```
    重试刷写错误的项
    
    返回:
    
    true/false
  - daemonFlushing
```
public void daemonFlushing()
```
    执行刷写任务
  - toString
```
public String toString()
```
    覆盖:
    
    toString 在类中 Object

类 DelayFlusher

字段概要

构造器概要

方法概要

从类继承的方法 java.lang.Object

字段详细资料

_Logger

STATE_FLUSH_CLOSED

STATE_REINDEX_CLOSED

STATE_CLOSED

STATE_STOP

STATE_FLUSH_STARTING

STATE_PERIOD

BUSY_PERIOD

BUSY_DELAY

BUSY_REINDEX

BUSY_FAIL

BUSY_MASK_STATE

BUSY_MASK_COUNT

m_Name

m_DelayList

m_FailList

m_Lock

m_WaitWriteTask

m_FlushInterval

m_MaxSuspend

m_State

m_LastDelayFlush

m_ThreadFlush

m_Busy

m_FlushPending

m_FlushPeriod

m_LastPeriodFlush

构造器详细资料

DelayFlusher

DelayFlusher

方法详细资料

setName

getName

setMaxSuspend

getMaxSuspend

markOnFail

mark

flush

flush

destroySignal

destroy

close

finalize

flushing

getFlushPending

tryFailFlushing

daemonFlushing

toString