com.asakusafw.workflow.executor.basic

Class BasicJobflowExecutor

java.lang.Object

com.asakusafw.workflow.executor.basic.BasicJobflowExecutor

All Implemented Interfaces:

JobflowExecutor

public class BasicJobflowExecutor
extends Object
implements JobflowExecutor

Executes jobflows.

Since:

0.10.0

Constructor Summary

Constructors

Constructor and Description
BasicJobflowExecutor(Collection<? extends TaskExecutor> taskExecutors) Creates a new instance.
BasicJobflowExecutor(TaskExecutor... taskExecutors) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	execute(TaskExecutionContext context, JobflowInfo jobflow) Executes the given jobflow.

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicJobflowExecutor

public BasicJobflowExecutor(Collection<? extends TaskExecutor> taskExecutors)

Creates a new instance.

Parameters:

taskExecutors - the task executors

BasicJobflowExecutor

public BasicJobflowExecutor(TaskExecutor... taskExecutors)

Creates a new instance.

Parameters:

taskExecutors - the task executors

Method Detail

execute

public void execute(TaskExecutionContext context,
                    JobflowInfo jobflow)
             throws IOException,
                    InterruptedException

Description copied from interface: JobflowExecutor

Executes the given jobflow.

Specified by:

execute in interface JobflowExecutor

Parameters:

context - the current context

jobflow - target jobflow

Throws:

IOException - if failed to create job processes

InterruptedException - if interrupted while running tasks