org.jgroups.util

Class ResponseCollectorTask<T>

java.lang.Object

org.jgroups.util.ResponseCollector<T>

org.jgroups.util.ResponseCollectorTask<T>

All Implemented Interfaces:

Condition

public class ResponseCollectorTask<T>
extends ResponseCollector<T>

Task which is seeded with an initial membership. Periodically executes a runnable (which e.g. sends a message) and stops when responses from all members have been received, or the task is stopped.

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ResponseCollectorTask.Consumer<C>

Field Summary

Fields

Modifier and Type	Field and Description
protected ResponseCollectorTask.Consumer<ResponseCollectorTask<T>>	finalizer_task
protected ResponseCollectorTask.Consumer<ResponseCollectorTask<T>>	periodic_task
protected java.util.concurrent.Future<?>	runner
protected java.lang.Runnable	stub

Constructor Summary

Constructors

Constructor and Description
ResponseCollectorTask()
ResponseCollectorTask(Address... members)
ResponseCollectorTask(java.util.Collection<Address> members)

Method Summary

Modifier and Type	Method and Description
boolean	add(Address member, T data)
boolean	isDone()
boolean	retainAll(java.util.List<Address> members)
ResponseCollectorTask<T>	setFinalizerTask(ResponseCollectorTask.Consumer<ResponseCollectorTask<T>> r)
ResponseCollectorTask<T>	setPeriodicTask(ResponseCollectorTask.Consumer<ResponseCollectorTask<T>> pt)
ResponseCollectorTask<T>	start(TimeScheduler timer, long initial_delay, long interval)
ResponseCollectorTask<T>	stop()

Methods inherited from class org.jgroups.util.ResponseCollector

getMissing, getResults, getValidResults, hasAllResponses, isMet, numberOfValidResponses, remove, remove, reset, reset, reset, size, suspect, toString, waitForAllResponses

Methods inherited from class java.lang.Object

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

Field Detail

periodic_task

protected ResponseCollectorTask.Consumer<ResponseCollectorTask<T>> periodic_task

finalizer_task

protected ResponseCollectorTask.Consumer<ResponseCollectorTask<T>> finalizer_task

runner

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

stub

protected final java.lang.Runnable stub

Constructor Detail

ResponseCollectorTask

public ResponseCollectorTask()

ResponseCollectorTask

public ResponseCollectorTask(java.util.Collection<Address> members)

ResponseCollectorTask

public ResponseCollectorTask(Address... members)

Method Detail

setPeriodicTask

public ResponseCollectorTask<T> setPeriodicTask(ResponseCollectorTask.Consumer<ResponseCollectorTask<T>> pt)

setFinalizerTask

public ResponseCollectorTask<T> setFinalizerTask(ResponseCollectorTask.Consumer<ResponseCollectorTask<T>> r)

isDone

public boolean isDone()

start

public ResponseCollectorTask<T> start(TimeScheduler timer,
                                      long initial_delay,
                                      long interval)

stop

public ResponseCollectorTask<T> stop()

add

public boolean add(Address member,
                   T data)

Overrides:

add in class ResponseCollector<T>

retainAll

public boolean retainAll(java.util.List<Address> members)

Overrides:

retainAll in class ResponseCollector<T>