net.imglib2.cache.queue

Class FetcherThreads

java.lang.Object

net.imglib2.cache.queue.FetcherThreads

public class FetcherThreads
extends Object

TODO revise javadoc A set of threads that load data. Each thread does the following in a loop:

1. Take the next key from a queue.
2. Try loading the key's data (retry until that succeeds).

FetcherThreads are employed by the cache to asynchronously load values.

Author:

Tobias Pietzsch

Constructor Summary

Constructors

Constructor and Description
FetcherThreads(BlockingFetchQueues<Callable<?>> queue, int numFetcherThreads) Create (and start) a set of fetcher threads.
FetcherThreads(BlockingFetchQueues<Callable<?>> queue, int numFetcherThreads, IntFunction<String> threadIndexToName) Create (and start) a set of fetcher threads.

Method Summary

Modifier and Type	Method and Description
void	pauseFor(long ms) Pause all Fetcher threads for the specified number of milliseconds.
void	pauseUntil(long timeMillis) pause all Fetcher threads until the given time (see System.currentTimeMillis()).
void	shutdown()
void	wakeUp() Wake up all Fetcher threads immediately.

Methods inherited from class java.lang.Object

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

Constructor Detail

FetcherThreads

public FetcherThreads(BlockingFetchQueues<Callable<?>> queue,
                      int numFetcherThreads)

Create (and start) a set of fetcher threads.

Fetcher threads are named Fetcher-0 ... Fetcher-n.

Parameters:

queue - the queue from which request keys are taken.

numFetcherThreads - how many parallel fetcher threads to start.

FetcherThreads

public FetcherThreads(BlockingFetchQueues<Callable<?>> queue,
                      int numFetcherThreads,
                      IntFunction<String> threadIndexToName)

Create (and start) a set of fetcher threads.

Parameters:

queue - the queue from which request keys are taken.

numFetcherThreads - how many parallel fetcher threads to start.

threadIndexToName - a function for naming fetcher threads (takes an index and returns a name).

Method Detail

pauseFor

public void pauseFor(long ms)

Pause all Fetcher threads for the specified number of milliseconds.

pauseUntil

public void pauseUntil(long timeMillis)

pause all Fetcher threads until the given time (see System.currentTimeMillis()).

wakeUp

public void wakeUp()

Wake up all Fetcher threads immediately. This ends any pauseFor(long) and pauseUntil(long) set earlier.

shutdown

public void shutdown()