TaskMergeProcessorStrategy (registry-server-session 5.3.0 API)

跳过导航链接

所有类

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

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

所有已知实现类:

DefaultPushTaskMergeProcessor
```
public interface TaskMergeProcessorStrategy<T>
```
版本:

$Id: TaskMergeProcessorStrategy.java, v 0.1 2018-12-19 12:03 shangyu.wh Exp $

作者:

shangyu.wh

方法概要

所有方法实例方法抽象方法
限定符和类型	方法和说明
`AtomicInteger`	`getOverrideTaskSize()`
`Integer`	`getPendingTaskSize()`
`AtomicInteger`	`getPutTaskSize()`
`AtomicInteger`	`getSendTaskSize()`
`void`	`handleEvent(TaskEvent event)`
`void`	`init(T pushTaskSender)`

方法详细资料

init
```
void init(T pushTaskSender)
```

handleEvent
```
void handleEvent(TaskEvent event)
```

getPutTaskSize
```
AtomicInteger getPutTaskSize()
```

getOverrideTaskSize
```
AtomicInteger getOverrideTaskSize()
```

getSendTaskSize
```
AtomicInteger getSendTaskSize()
```

getPendingTaskSize
```
Integer getPendingTaskSize()
```

跳过导航链接

所有类

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

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

Copyright © 2019 The Ant Financial. All rights reserved.