com.asakusafw.yaess.paralleljob

Class ParallelJobExecutor

java.lang.Object

com.asakusafw.yaess.paralleljob.ParallelJobExecutor

All Implemented Interfaces:

JobExecutor

public class ParallelJobExecutor
extends Object
implements JobExecutor

An implementation of ParallelJobExecutor which use multiple threads for each resource.

Since:

0.2.3

Nested Class Summary

Nested classes/interfaces inherited from interface com.asakusafw.yaess.basic.JobExecutor

JobExecutor.Executing

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_RESOURCE_ID The default resource name.
static String	KEY_PARALLEL_PREFIX The key prefix of multiplexity configuration each resources.

Constructor Summary

Constructors

Constructor and Description
ParallelJobExecutor(int defaultResuorce, Map<String,Integer> threadConfig) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
static ParallelJobExecutor	extract(String servicePrefix, Map<String,String> configuration, VariableResolver variables) Extracts multiplexity profiles from configuration and returns a related executor.
JobExecutor.Executing	submit(ExecutionMonitor monitor, ExecutionContext context, Job job, BlockingQueue<JobExecutor.Executing> doneQueue) Submits a job.

Methods inherited from class java.lang.Object

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

Field Detail

KEY_PARALLEL_PREFIX

public static final String KEY_PARALLEL_PREFIX

The key prefix of multiplexity configuration each resources.

See Also:

Constant Field Values

DEFAULT_RESOURCE_ID

public static final String DEFAULT_RESOURCE_ID

The default resource name.

See Also:

Constant Field Values

Constructor Detail

ParallelJobExecutor

public ParallelJobExecutor(int defaultResuorce,
                           Map<String,Integer> threadConfig)

Creates a new instance.

Parameters:

defaultResuorce - default resource multiplexity

threadConfig - each resource multiplexity

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

extract

public static ParallelJobExecutor extract(String servicePrefix,
                                          Map<String,String> configuration,
                                          VariableResolver variables)

Extracts multiplexity profiles from configuration and returns a related executor.

This operation extracts following entries from configuration:

• parallel.<resource-name> -

Profiles must be contain parallel.default.

Parameters:

servicePrefix - prefix of configuration keys

configuration - target configuration

variables - variable resolver

Returns:

the created executor

Throws:

IllegalArgumentException - if configuration is invalid

submit

public JobExecutor.Executing submit(ExecutionMonitor monitor,
                                    ExecutionContext context,
                                    Job job,
                                    BlockingQueue<JobExecutor.Executing> doneQueue)
                             throws InterruptedException,
                                    IOException

Description copied from interface: JobExecutor

Submits a job.

Specified by:

submit in interface JobExecutor

Parameters:

monitor - an execution monitor

context - current context

job - target job

doneQueue - the queue where the done tasks are put

Returns:

an execution object related to the target job

Throws:

InterruptedException - if submittion is interrupted

IOException - if failed to submit the target job