freenet.support

Class TrivialTicker

java.lang.Object

freenet.support.TrivialTicker

All Implemented Interfaces:

Ticker

public class TrivialTicker
extends java.lang.Object
implements Ticker

Ticker implemented using Timer's. If deploying this to replace PacketSender, be careful to handle priority changes properly. Hopefully that can be achieved simply by creating at max priority during startup.

Constructor Summary

Constructors

Constructor and Description
TrivialTicker(Executor executor)

Method Summary

Modifier and Type	Method and Description
void	cancelTimedJob(java.lang.Runnable job)
Executor	getExecutor() Get the underlying Executor.
void	queueTimedJob(java.lang.Runnable job, long offset) Run a job after a given delay.
void	queueTimedJob(java.lang.Runnable job, java.lang.String name, long offset, boolean runOnTickerAnyway, boolean noDupes) Run a job after a given delay.
void	queueTimedJobAbsolute(java.lang.Runnable runner, java.lang.String name, long time, boolean runOnTickerAnyway, boolean noDupes) Run a job at a specified absolute time.
void	removeQueuedJob(java.lang.Runnable job) Remove a queued job.
void	rescheduleTimedJob(java.lang.Runnable job, java.lang.String name, long newOffset) Changes the offset of a already-queued job.
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

TrivialTicker

public TrivialTicker(Executor executor)

Method Detail

queueTimedJob

public void queueTimedJob(java.lang.Runnable job,
                          long offset)

Description copied from interface: Ticker

Run a job after a given delay.

Specified by:

queueTimedJob in interface Ticker

Parameters:

job - The Runnable to execute.

offset - The delay in milliseconds.

queueTimedJob

public void queueTimedJob(java.lang.Runnable job,
                          java.lang.String name,
                          long offset,
                          boolean runOnTickerAnyway,
                          boolean noDupes)

Description copied from interface: Ticker

Run a job after a given delay.

Specified by:

queueTimedJob in interface Ticker

Parameters:

job - The Runnable to execute.

name - The name of the thread to run it.

offset - The delay in milliseconds.

runOnTickerAnyway - If true, start the job from the Ticker thread even if we could pass it directly through to the Executor. This is needed for increasing thread priorities, since the Ticker runs at a high priority, and for some tests.

noDupes - If true, ignore the job if it is already queued. Implies runOnTickerAnyway. WARNING: This does not guarantee that we don't run multiple copies of the job simultaneously! You must ensure adequate locking. Worse, if the job takes an unexpectedly long time, you could end up with many copies of the job running simultaneously.

cancelTimedJob

public void cancelTimedJob(java.lang.Runnable job)

removeQueuedJob

public void removeQueuedJob(java.lang.Runnable job)

Description copied from interface: Ticker

Remove a queued job.

Specified by:

removeQueuedJob in interface Ticker

rescheduleTimedJob

public void rescheduleTimedJob(java.lang.Runnable job,
                               java.lang.String name,
                               long newOffset)

Changes the offset of a already-queued job. If the given job was not queued yet it will be queued nevertheless.

shutdown

public void shutdown()

getExecutor

public Executor getExecutor()

Description copied from interface: Ticker

Get the underlying Executor.

Specified by:

getExecutor in interface Ticker

queueTimedJobAbsolute

public void queueTimedJobAbsolute(java.lang.Runnable runner,
                                  java.lang.String name,
                                  long time,
                                  boolean runOnTickerAnyway,
                                  boolean noDupes)

Description copied from interface: Ticker

Run a job at a specified absolute time.

Specified by:

queueTimedJobAbsolute in interface Ticker

name - The name of the thread to run it.

time - The time at which to run the job.

runOnTickerAnyway - If true, start the job from the Ticker thread even if we could pass it directly through to the Executor. This is needed for increasing thread priorities, since the Ticker runs at a high priority, and for some tests.

noDupes - If true, ignore the job if it is already queued. Implies runOnTickerAnyway. WARNING: This does not guarantee that we don't run multiple copies of the job simultaneously! You must ensure adequate locking. Worse, if the job takes an unexpectedly long time, you could end up with many copies of the job running simultaneously.