com.asakusafw.workflow.executor.basic

Class BasicCommandTaskExecutor

java.lang.Object

com.asakusafw.workflow.executor.basic.BasicCommandTaskExecutor

All Implemented Interfaces:

TaskExecutor

Direct Known Subclasses:

DefaultCommandTaskExecutor

public class BasicCommandTaskExecutor
extends Object
implements TaskExecutor

Executes CommandTaskInfo via fork/exec.

Since:

0.10.0

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	WINDOWS Whether the running System is Windows or not.

Constructor Summary

Constructors

Constructor and Description
BasicCommandTaskExecutor() Creates a new instance.
BasicCommandTaskExecutor(Function<? super TaskExecutionContext,? extends CommandLauncher> launchers) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
static void	execute(TaskExecutionContext context, CommandLauncher launcher, Path command, List<String> arguments) Executes a command.
static void	execute(TaskExecutionContext context, Path command, List<String> arguments) Executes a command.
void	execute(TaskExecutionContext context, TaskInfo task) Executes a task.
static CommandLauncher	getCommandLauncher(ExecutionContext context) Returns a CommandLauncher.
static CommandLauncher	getCommandLauncher(ExecutionContext context, BasicCommandLauncher.OutputConsumer output) Returns a CommandLauncher.
boolean	isSupported(TaskExecutionContext context, TaskInfo task) Returns whether this executor supports executing the target task.

Methods inherited from class java.lang.Object

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

Field Detail

WINDOWS

public static final boolean WINDOWS

Whether the running System is Windows or not.

Constructor Detail

BasicCommandTaskExecutor

public BasicCommandTaskExecutor()

Creates a new instance.

BasicCommandTaskExecutor

public BasicCommandTaskExecutor(Function<? super TaskExecutionContext,? extends CommandLauncher> launchers)

Creates a new instance.

Parameters:

launchers - the command launcher provider

Method Detail

isSupported

public boolean isSupported(TaskExecutionContext context,
                           TaskInfo task)

Description copied from interface: TaskExecutor

Returns whether this executor supports executing the target task.

Specified by:

isSupported in interface TaskExecutor

Parameters:

context - the current context

task - the target task

Returns:

true if this supports the target task, otherwise false

execute

public void execute(TaskExecutionContext context,
                    TaskInfo task)
             throws InterruptedException,
                    IOException

Description copied from interface: TaskExecutor

Executes a task.

Specified by:

execute in interface TaskExecutor

Parameters:

context - the current context

task - the target task

Throws:

InterruptedException - if interrupted while executing the task

IOException - if task execution was failed

getCommandLauncher

public static CommandLauncher getCommandLauncher(ExecutionContext context)

Returns a CommandLauncher.

Parameters:

context - the current context

Returns:

the command launcher

getCommandLauncher

public static CommandLauncher getCommandLauncher(ExecutionContext context,
                                                 BasicCommandLauncher.OutputConsumer output)

Returns a CommandLauncher.

Parameters:

context - the current context

output - the output target

Returns:

the command launcher

execute

public static void execute(TaskExecutionContext context,
                           Path command,
                           List<String> arguments)
                    throws IOException,
                           InterruptedException

Executes a command.

Parameters:

context - the current context

command - the command path

arguments - the resolved arguments

Throws:

IOException - if I/O error was occurred while executing the command

InterruptedException - if interrupted while executing the command

execute

public static void execute(TaskExecutionContext context,
                           CommandLauncher launcher,
                           Path command,
                           List<String> arguments)
                    throws IOException,
                           InterruptedException

Executes a command.

Parameters:

context - the current context

launcher - the command launcher

command - the command path

arguments - the resolved arguments

Throws:

IOException - if I/O error was occurred while executing the command

InterruptedException - if interrupted while executing the command