com.alipay.sofa.registry.server.session.strategy.impl

类 DefaultPushTaskMergeProcessor<T extends PushTaskSender>

java.lang.Object

com.alipay.sofa.registry.server.session.strategy.impl.DefaultPushTaskMergeProcessor<T>

所有已实现的接口:

TaskMergeProcessorStrategy<T>

public class DefaultPushTaskMergeProcessor<T extends PushTaskSender>
extends Object
implements TaskMergeProcessorStrategy<T>

版本:

$Id: TaskMergeUtil.java, v 0.1 2018-12-10 18:35 shangyu.wh Exp $

作者:

shangyu.wh

构造器概要

构造器

构造器和说明
DefaultPushTaskMergeProcessor()

方法概要

限定符和类型	方法和说明
AtomicInteger	getOverrideTaskSize()
Integer	getPendingTaskSize()
AtomicInteger	getPutTaskSize()
AtomicInteger	getSendTaskSize()
void	handleEvent(TaskEvent event)
void	init(T pushTaskSender)

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DefaultPushTaskMergeProcessor

public DefaultPushTaskMergeProcessor()

方法详细资料

init

public void init(T pushTaskSender)

指定者:

init 在接口中 TaskMergeProcessorStrategy<T extends PushTaskSender>

handleEvent

public void handleEvent(TaskEvent event)

指定者:

handleEvent 在接口中 TaskMergeProcessorStrategy<T extends PushTaskSender>

getPutTaskSize

public AtomicInteger getPutTaskSize()

指定者:

getPutTaskSize 在接口中 TaskMergeProcessorStrategy<T extends PushTaskSender>

getOverrideTaskSize

public AtomicInteger getOverrideTaskSize()

指定者:

getOverrideTaskSize 在接口中 TaskMergeProcessorStrategy<T extends PushTaskSender>

getSendTaskSize

public AtomicInteger getSendTaskSize()

指定者:

getSendTaskSize 在接口中 TaskMergeProcessorStrategy<T extends PushTaskSender>

getPendingTaskSize

public Integer getPendingTaskSize()

指定者:

getPendingTaskSize 在接口中 TaskMergeProcessorStrategy<T extends PushTaskSender>