Package fr.ens.biologie.genomique.eoulsan.core.schedulers

Class MultiThreadTaskScheduler

java.lang.Object

fr.ens.biologie.genomique.eoulsan.core.schedulers.AbstractTaskScheduler

fr.ens.biologie.genomique.eoulsan.core.schedulers.MultiThreadTaskScheduler

All Implemented Interfaces:

TaskScheduler, Runnable

public class MultiThreadTaskScheduler
extends AbstractTaskScheduler
implements Runnable

This class define a muti thread scheduler.

Since:

2.0

Author:

Laurent Jourdren

Constructor Summary

Constructors

Constructor	Description
MultiThreadTaskScheduler(int threadNumber)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	pause()
void	resume()
void	run()
void	start()	Start the scheduler.
void	stop()	Stop the scheduler.
void	submit(Step step, TaskContextImpl context)	Submit a context to execute.

Methods inherited from class fr.ens.biologie.genomique.eoulsan.core.schedulers.AbstractTaskScheduler

getResult, getStatus, getTaskDoneCount, getTaskRunningCount, getTaskSubmittedCount, getTotalTaskDoneCount, getTotalTaskRunningCount, getTotalTaskSubmittedCount, submit, waitEndOfTasks

Methods inherited from class java.lang.Object

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

Constructor Details

MultiThreadTaskScheduler

public MultiThreadTaskScheduler(int threadNumber)

Constructor.

Parameters:

threadNumber - number of thread to use by the task scheduler

Method Details

submit

public void submit(Step step,
 TaskContextImpl context)

Description copied from interface: TaskScheduler

Submit a context to execute.

Specified by:

submit in interface TaskScheduler

Overrides:

submit in class AbstractTaskScheduler

Parameters:

step - step related to the context

context - context to execute

start

public void start()

Description copied from interface: TaskScheduler

Start the scheduler.

Specified by:

start in interface TaskScheduler

Overrides:

start in class AbstractTaskScheduler

stop

public void stop()

Description copied from interface: TaskScheduler

Stop the scheduler.

Specified by:

stop in interface TaskScheduler

Overrides:

stop in class AbstractTaskScheduler

pause

public void pause()

resume

public void resume()

run

public void run()

Specified by:

run in interface Runnable