Package me.ahoo.cosid.segment.concurrent

Class DefaultPrefetchWorker

java.lang.Object

java.lang.Thread

me.ahoo.cosid.segment.concurrent.DefaultPrefetchWorker

All Implemented Interfaces:

Runnable, PrefetchWorker

public class DefaultPrefetchWorker
extends Thread
implements PrefetchWorker

Default prefetch worker implementation.

Runs a background thread that periodically executes affinity jobs to prefetch ID segments before they are exhausted.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
DefaultPrefetchWorker(Duration prefetchPeriod)	Creates a worker with specified prefetch period.

Method Summary

Modifier and Type	Method	Description
void	cancel(AffinityJob affinityJob)	Cancels a prefetch job.
void	run()
void	shutdown()	Shuts down the worker.
void	submit(AffinityJob affinityJob)	Submits a job for prefetching.
void	wakeup(AffinityJob affinityJob)	Wakes up a job for immediate processing.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface me.ahoo.cosid.segment.concurrent.PrefetchWorker

getName

Constructor Details

DefaultPrefetchWorker

public DefaultPrefetchWorker(Duration prefetchPeriod)

Creates a worker with specified prefetch period.

Parameters:

prefetchPeriod - the period between prefetch runs

Method Details

shutdown

public void shutdown()

Description copied from interface: PrefetchWorker

Shuts down the worker.

Specified by:

shutdown in interface PrefetchWorker

submit

public void submit(AffinityJob affinityJob)

Description copied from interface: PrefetchWorker

Submits a job for prefetching.

Specified by:

submit in interface PrefetchWorker

Parameters:

affinityJob - the job to submit

cancel

public void cancel(AffinityJob affinityJob)

Description copied from interface: PrefetchWorker

Cancels a prefetch job.

Specified by:

cancel in interface PrefetchWorker

Parameters:

affinityJob - the job to cancel

wakeup

public void wakeup(AffinityJob affinityJob)

Description copied from interface: PrefetchWorker

Wakes up a job for immediate processing.

Specified by:

wakeup in interface PrefetchWorker

Parameters:

affinityJob - the job to wake up

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread