Package kilim

Class ForkJoinScheduler

java.lang.Object

kilim.Scheduler

kilim.ForkJoinScheduler

All Implemented Interfaces:

TimerService.WatchdogContext

public class ForkJoinScheduler
extends Scheduler
implements TimerService.WatchdogContext

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	ForkJoinScheduler.ForkedRunnable<V>

Nested classes/interfaces inherited from class kilim.Scheduler

Scheduler.BasicLogger, Scheduler.Logger

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.concurrent.atomic.AtomicInteger	count
(package private) java.util.concurrent.ForkJoinPool	pool
private TimerService	timerService

Fields inherited from class kilim.Scheduler

defaultLogger, defaultNumberThreads, defaultScheduler, pinnableScheduler, shutdown

Constructor Summary

Constructors

Constructor	Description
ForkJoinScheduler(int numThreads)

Method Summary

Modifier and Type	Method	Description
void	idledown()	block the thread till a moment at which all scheduled tasks have completed and then shutdown the scheduler does not prevent scheduling new tasks (from other threads) until the shutdown is complete so such a task could be partially executed
boolean	isEmpty()
boolean	isEmptyish()	are the queues empty allows false positives, but not false negatives ie, if this method returns false, then at some moment during the call at least one queue was non-empty if it returns true then for each queue there was a moment during the call when it was empty
boolean	isPinnable()
static void	main(java.lang.String[] args)	run the main method from another class using this scheduler as the default scheduler
int	numThreads()
private static java.lang.Integer	parseNum(java.lang.String[] args, int index)
private static java.lang.String[]	processArgs(java.lang.String[] args, int offset)
void	publish(java.lang.Runnable task)
void	publish(TimerService.WatchdogTask dog)
private static void	run(java.lang.String className, java.lang.String method, java.lang.String... args)
void	schedule(int index, Task task)	schedule a task to run
void	scheduleTimer(Timer t)
void	shutdown()
boolean	waitIdle(int delay)

Methods inherited from class kilim.Scheduler

getCurrentTask, getDefaultPinnable, getDefaultScheduler, getPinnable, isShutdown, log, logRelay, make, schedule, setCurrentTask, setDefaultPinnable, setDefaultScheduler, setLogger

Methods inherited from class java.lang.Object

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

Field Detail

pool

java.util.concurrent.ForkJoinPool pool

timerService

private TimerService timerService

count

private java.util.concurrent.atomic.AtomicInteger count

Constructor Detail

ForkJoinScheduler

public ForkJoinScheduler(int numThreads)

Method Detail

publish

public void publish(TimerService.WatchdogTask dog)

Specified by:

publish in interface TimerService.WatchdogContext

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface TimerService.WatchdogContext

isPinnable

public boolean isPinnable()

Overrides:

isPinnable in class Scheduler

schedule

public void schedule(int index,
                     Task task)

Description copied from class: Scheduler

schedule a task to run

Specified by:

schedule in class Scheduler

Parameters:

index - the index of the executor to use, or less than zero to use the default (round robin) assignment

task - the task

publish

public void publish(java.lang.Runnable task)

isEmptyish

public boolean isEmptyish()

Description copied from class: Scheduler

are the queues empty allows false positives, but not false negatives ie, if this method returns false, then at some moment during the call at least one queue was non-empty if it returns true then for each queue there was a moment during the call when it was empty

Specified by:

isEmptyish in interface TimerService.WatchdogContext

Specified by:

isEmptyish in class Scheduler

numThreads

public int numThreads()

Specified by:

numThreads in class Scheduler

scheduleTimer

public void scheduleTimer(Timer t)

Specified by:

scheduleTimer in class Scheduler

idledown

public void idledown()

Description copied from class: Scheduler

block the thread till a moment at which all scheduled tasks have completed and then shutdown the scheduler does not prevent scheduling new tasks (from other threads) until the shutdown is complete so such a task could be partially executed

Specified by:

idledown in class Scheduler

waitIdle

public boolean waitIdle(int delay)

shutdown

public void shutdown()

Overrides:

shutdown in class Scheduler

processArgs

private static java.lang.String[] processArgs(java.lang.String[] args,
                                              int offset)

parseNum

private static java.lang.Integer parseNum(java.lang.String[] args,
                                          int index)

run

private static void run(java.lang.String className,
                        java.lang.String method,
                        java.lang.String... args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

run the main method from another class using this scheduler as the default scheduler

Throws:

java.lang.Exception