org.threadly.concurrent

Class Poller

java.lang.Object

org.threadly.concurrent.Poller

public class Poller
extends java.lang.Object

Simple class for watching a condition and getting notified when a state has changed. One handy tool is the ability to transition java's Future into Threadly's much nicer ListenableFuture.

The frequency at which this polls should be determined based off how cheap polling is, and how many items will be polled on average.

If being allowed to garbage collect, this poller will continue to schedule itself as long as there are outstanding futures. Once all have completed (from timeout or naturally), then this will stop scheduling itself to poll for updates. Thus no explicit cleanup is needed. As long as the Supplier's are quick/fast (Future conversions are always quick/fast), it's most efficient to reuse the Poller instance. But if you need dynamic timeout's/max wait time you could construct a Poller and toss it away once you get the returned ListenableFuture from it.

Since:

5.0

Constructor Summary

Constructors

Constructor and Description
Poller(SchedulerService scheduler, long pollFrequency) Construct a new poller which will run on the provided scheduler, and run at the specified frequency.
Poller(SchedulerService scheduler, long pollFrequency, long maxWaitTime) Construct a new poller which will run on the provided scheduler, and run at the specified frequency.

Method Summary

Modifier and Type	Method and Description
<T> ListenableFuture<T>	watch(java.util.concurrent.Future<? extends T> f) Convert a conventional Future into a ListenableFuture.
ListenableFuture<?>	watch(java.util.function.Supplier<java.lang.Boolean> p) Watch suppliers returned condition.

Methods inherited from class java.lang.Object

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

Constructor Detail

Poller

public Poller(SchedulerService scheduler,
              long pollFrequency)

Construct a new poller which will run on the provided scheduler, and run at the specified frequency.

Parameters:

scheduler - Scheduler to run polling task on

pollFrequency - Time in milliseconds to wait between polling events

Poller

public Poller(SchedulerService scheduler,
              long pollFrequency,
              long maxWaitTime)

Construct a new poller which will run on the provided scheduler, and run at the specified frequency.

This constructor additionally allows you to specify the maximum time in millseconds we should wait for the condition to become true. At this point if we are still not seeing our expected polling state, then the return future will be canceled.

Parameters:

scheduler - Scheduler to run polling task on

pollFrequency - Time in milliseconds to wait between polling events

maxWaitTime - Maximum time in milliseconds till returned futures should be canceled

Method Detail

watch

public ListenableFuture<?> watch(java.util.function.Supplier<java.lang.Boolean> p)

Watch suppliers returned condition. Once Supplier is witnessed in the true state, the returned future is completed. Listeners and FutureCallback's executed on the returned future without a specified pool will run on the polling thread, and so should be kept to a minimum.

Parameters:

p - Supplier to provide state for when poll has completed as expected

Returns:

Future to complete once boolean state is witnessed as true

watch

public <T> ListenableFuture<T> watch(java.util.concurrent.Future<? extends T> f)

Convert a conventional Future into a ListenableFuture. As poller runs it will check if the provided future has completed. Once it does complete the returned future will also complete in the exact same way. Canceling the returned future will have NO impact on the provided future (and thus the use with a timeout is not a concern to interrupting the provided future). Because this is only checked at poll intervals the returned future's completion will be delayed by that polling delay.

Type Parameters:

T - Type of object returned from future

Parameters:

f - Future to monitor for completetion

Returns:

ListenableFuture that will provide the result from the source future