com.fr.third.jgroups.protocols

类 MERGE2.FindSubgroupsTask

java.lang.Object

com.fr.third.jgroups.protocols.MERGE2.FindSubgroupsTask

封闭类:

MERGE2

protected class MERGE2.FindSubgroupsTask
extends java.lang.Object

Task periodically executing (if role is coordinator). Gets the initial membership and determines whether there are subgroups (multiple coordinators for the same group). If yes, it sends a MERGE event with the list of the coordinators up the stack

字段概要

字段

限定符和类型	字段和说明
protected java.util.concurrent.Future<?>	future
protected java.util.concurrent.locks.Lock	lock

构造器概要

构造器

限定符	构造器和说明
protected	MERGE2.FindSubgroupsTask()

方法概要

方法

限定符和类型	方法和说明
protected void	_findAndNotify()
protected long	computeInterval() Returns a random value within [min_interval - max_interval]
protected void	fetchViews() Fetches views from members in the cluster.
void	findAndNotify()
boolean	isRunning()
void	start()
void	stop()

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

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

字段详细资料

future

protected java.util.concurrent.Future<?> future

lock

protected final java.util.concurrent.locks.Lock lock

构造器详细资料

MERGE2.FindSubgroupsTask

protected MERGE2.FindSubgroupsTask()

方法详细资料

start

public void start()

stop

public void stop()

isRunning

public boolean isRunning()

findAndNotify

public void findAndNotify()

_findAndNotify

protected void _findAndNotify()
                       throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

fetchViews

protected void fetchViews()
                   throws java.lang.InterruptedException

Fetches views from members in the cluster. Returns when either discovery_timeout ms have elapsed or more than 1 different view has been found

抛出:

java.lang.InterruptedException

computeInterval

protected long computeInterval()

Returns a random value within [min_interval - max_interval]