com.asakusafw.yaess.core

Class JobScheduler

java.lang.Object

com.asakusafw.yaess.core.JobScheduler

All Implemented Interfaces:

Service

Direct Known Subclasses:

AbstractJobScheduler

public abstract class JobScheduler
extends Object
implements Service

Executes a series of Jobs.

Since:

0.2.3

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JobScheduler.ErrorHandler Handles errors during each job execution.

Field Summary

Fields

Modifier and Type	Field and Description
static JobScheduler.ErrorHandler	BEST_EFFORT Continue execution on exception occurred.
static JobScheduler.ErrorHandler	STRICT Terminate execution on exception occurred.

Constructor Summary

Constructors

Constructor and Description
JobScheduler()

Method Summary

Modifier and Type	Method and Description
void	configure(ServiceProfile<?> profile) Configures this service.
protected void	doConfigure(ServiceProfile<?> profile) Configures this service internally (extention point).
abstract void	execute(PhaseMonitor monitor, ExecutionContext context, List<? extends Job> jobs, JobScheduler.ErrorHandler errorHandler) Executes a series of jobs.

Methods inherited from class java.lang.Object

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

Field Detail

STRICT

public static final JobScheduler.ErrorHandler STRICT

Terminate execution on exception occurred.

BEST_EFFORT

public static final JobScheduler.ErrorHandler BEST_EFFORT

Continue execution on exception occurred.

Constructor Detail

JobScheduler

public JobScheduler()

Method Detail

configure

public final void configure(ServiceProfile<?> profile)
                     throws InterruptedException,
                            IOException

Description copied from interface: Service

Configures this service. This method will be invoked only once when this instance is created from the profile.

Specified by:

configure in interface Service

Parameters:

profile - the profile of this service

Throws:

InterruptedException - if interrupted in configuration

IOException - if failed to configure this service

doConfigure

protected void doConfigure(ServiceProfile<?> profile)
                    throws InterruptedException,
                           IOException

Configures this service internally (extention point).

Parameters:

profile - profile of this service

Throws:

InterruptedException - if interrupted this configuration

IOException - if failed to configure

execute

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

Executes a series of jobs.

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