Package org.jgroups.util

Class ResponseCollectorTask<T>

java.lang.Object

org.jgroups.util.ResponseCollector<T>

org.jgroups.util.ResponseCollectorTask<T>

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.

Since:

4.0.5

Field Summary

Fields

Modifier and Type	Field	Description
protected Consumer<ResponseCollectorTask<T>>	finalizer_task
protected Consumer<ResponseCollectorTask<T>>	periodic_task
protected Future<?>	runner
protected final Runnable	stub

Constructor Summary

Constructors

Constructor	Description
ResponseCollectorTask()
ResponseCollectorTask(Collection<Address> members)
ResponseCollectorTask(Address... members)

Method Summary

Modifier and Type	Method	Description
boolean	add(Address member, T data)
boolean	isDone()
boolean	retainAll(List<Address> members)
ResponseCollectorTask<T>	setFinalizerTask(Consumer<ResponseCollectorTask<T>> r)
ResponseCollectorTask<T>	setPeriodicTask(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, 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 Details

periodic_task

protected Consumer<ResponseCollectorTask<T>> periodic_task

finalizer_task

protected Consumer<ResponseCollectorTask<T>> finalizer_task

runner

protected Future<?> runner

stub

protected final Runnable stub

Constructor Details

ResponseCollectorTask

public ResponseCollectorTask()

ResponseCollectorTask

public ResponseCollectorTask(Collection<Address> members)

ResponseCollectorTask

public ResponseCollectorTask(Address... members)

Method Details

setPeriodicTask

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

setFinalizerTask

public ResponseCollectorTask<T> setFinalizerTask(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(List<Address> members)

Overrides:

retainAll in class ResponseCollector<T>