freenet.support

Class MemoryLimitedJobRunner

java.lang.Object

freenet.support.MemoryLimitedJobRunner

public class MemoryLimitedJobRunner
extends java.lang.Object

Start jobs as long as there is sufficient memory (or other limited resource) available, then queue them. FIXME I bet there is something like this in the standard libraries?

Field Summary

Fields

Modifier and Type	Field and Description
long	capacity
static int	THREAD_PRIORITY

Constructor Summary

Constructors

Constructor and Description
MemoryLimitedJobRunner(long capacity, int maxThreads, Executor executor, int priorities)

Method Summary

Modifier and Type	Method and Description
long	getCapacity()
int	getMaxThreads()
int	getRunningThreads()
void	queueJob(MemoryLimitedJob job) Run the job if the counter is below some threshold, otherwise queue it.
void	setCapacity(long val)
void	setMaxThreads(int val)
void	shutdown()
void	waitForShutdown()

Methods inherited from class java.lang.Object

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

Field Detail

THREAD_PRIORITY

public static final int THREAD_PRIORITY

capacity

public long capacity

Constructor Detail

MemoryLimitedJobRunner

public MemoryLimitedJobRunner(long capacity,
                              int maxThreads,
                              Executor executor,
                              int priorities)

Method Detail

queueJob

public void queueJob(MemoryLimitedJob job)

Run the job if the counter is below some threshold, otherwise queue it. Will ignore if shutting down.

setMaxThreads

public void setMaxThreads(int val)

getMaxThreads

public int getMaxThreads()

getCapacity

public long getCapacity()

setCapacity

public void setCapacity(long val)

shutdown

public void shutdown()

waitForShutdown

public void waitForShutdown()

getRunningThreads

public int getRunningThreads()