freenet.support

Class PrioritizedSerialExecutor

java.lang.Object

freenet.support.PrioritizedSerialExecutor

All Implemented Interfaces:

java.util.concurrent.Executor

public class PrioritizedSerialExecutor
extends java.lang.Object
implements Executor

Constructor Summary

Constructors

Constructor and Description
PrioritizedSerialExecutor(int priority, int internalPriorityCount, int defaultPriority, boolean invertOrder)
PrioritizedSerialExecutor(int priority, int internalPriorityCount, int defaultPriority, boolean invertOrder, long jobTimeout, ExecutorIdleCallback callback, NodeStats statistics)

Method Summary

Modifier and Type	Method and Description
boolean	anyQueued()
void	execute(java.lang.Runnable job) Execute a job.
void	execute(java.lang.Runnable job, int prio, java.lang.String jobName)
void	execute(java.lang.Runnable job, java.lang.String jobName)
void	execute(java.lang.Runnable job, java.lang.String jobName, boolean fromTicker)
void	executeNoDupes(java.lang.Runnable job, int prio, java.lang.String jobName)
java.lang.Runnable[][]	getQueuedJobsByPriority()
int[]	getQueuedJobsCountByPriority()
int	getQueueSize(int priority)
int	getWaitingThreadsCount() Fast method returning how many threads are waiting
boolean	onThread()
int[]	runningThreads() Count the number of threads running at each priority level
void	start(Executor realExecutor, java.lang.String name)
int[]	waitingThreads() Count the number of threads waiting for work at each priority level

Methods inherited from class java.lang.Object

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

Constructor Detail

PrioritizedSerialExecutor

public PrioritizedSerialExecutor(int priority,
                                 int internalPriorityCount,
                                 int defaultPriority,
                                 boolean invertOrder,
                                 long jobTimeout,
                                 ExecutorIdleCallback callback,
                                 NodeStats statistics)

Parameters:

priority -

internalPriorityCount -

defaultPriority -

invertOrder - Set if the priorities are thread priorities. Unset if they are request priorities. D'oh!

PrioritizedSerialExecutor

public PrioritizedSerialExecutor(int priority,
                                 int internalPriorityCount,
                                 int defaultPriority,
                                 boolean invertOrder)

Method Detail

start

public void start(Executor realExecutor,
                  java.lang.String name)

execute

public void execute(java.lang.Runnable job)

Description copied from interface: Executor

Execute a job.

Specified by:

execute in interface java.util.concurrent.Executor

execute

public void execute(java.lang.Runnable job,
                    java.lang.String jobName)

execute

public void execute(java.lang.Runnable job,
                    int prio,
                    java.lang.String jobName)

executeNoDupes

public void executeNoDupes(java.lang.Runnable job,
                           int prio,
                           java.lang.String jobName)

execute

public void execute(java.lang.Runnable job,
                    java.lang.String jobName,
                    boolean fromTicker)

runningThreads

public int[] runningThreads()

Description copied from interface: Executor

Count the number of threads running at each priority level

waitingThreads

public int[] waitingThreads()

Description copied from interface: Executor

Count the number of threads waiting for work at each priority level

onThread

public boolean onThread()

getQueuedJobsCountByPriority

public int[] getQueuedJobsCountByPriority()

getQueuedJobsByPriority

public java.lang.Runnable[][] getQueuedJobsByPriority()

getQueueSize

public int getQueueSize(int priority)

getWaitingThreadsCount

public int getWaitingThreadsCount()

Description copied from interface: Executor

Fast method returning how many threads are waiting

anyQueued

public boolean anyQueued()