com.asakusafw.yaess.basic

Class AbstractJobScheduler

java.lang.Object

com.asakusafw.yaess.core.JobScheduler

com.asakusafw.yaess.basic.AbstractJobScheduler

All Implemented Interfaces:

Service

Direct Known Subclasses:

BasicJobScheduler, ParallelJobScheduler

public abstract class AbstractJobScheduler
extends JobScheduler

An abstract implementation of JobScheduler.

Since:

0.2.3

Nested Class Summary

Nested classes/interfaces inherited from class com.asakusafw.yaess.core.JobScheduler

JobScheduler.ErrorHandler

Field Summary

Fields inherited from class com.asakusafw.yaess.core.JobScheduler

BEST_EFFORT, STRICT

Constructor Summary

Constructors

Constructor and Description
AbstractJobScheduler()

Method Summary

Modifier and Type	Method and Description
void	execute(PhaseMonitor monitor, ExecutionContext context, List<? extends Job> jobs, JobScheduler.ErrorHandler errorHandler) Executes a series of jobs.
protected abstract JobExecutor	getJobExecutor() Returns a JobExecutor for this scheduler.

Methods inherited from class com.asakusafw.yaess.core.JobScheduler

configure, doConfigure

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractJobScheduler

public AbstractJobScheduler()

Method Detail

getJobExecutor

protected abstract JobExecutor getJobExecutor()

Returns a JobExecutor for this scheduler.

Returns:

the JobExecutor

execute

public final void execute(PhaseMonitor monitor,
                          ExecutionContext context,
                          List<? extends Job> jobs,
                          JobScheduler.ErrorHandler errorHandler)
                   throws InterruptedException,
                          IOException

Description copied from class: JobScheduler

Executes a series of jobs.

Specified by:

execute in class JobScheduler

Parameters:

monitor - the progress monitor of the execution

context - current execution context

jobs - jobs to be executed

errorHandler - handles errors during each job execution

Throws:

InterruptedException - if the execution was interrupted

IOException - if failed to execute the jobs