com.asakusafw.yaess.basic

Class ThreadedJobExecutor

java.lang.Object

com.asakusafw.yaess.basic.ThreadedJobExecutor

All Implemented Interfaces:

JobExecutor

public class ThreadedJobExecutor
extends Object
implements JobExecutor

An implementation of JobExecutor using a shared ExecutorService.

Since:

0.2.3

Nested Class Summary

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

JobExecutor.Executing

Constructor Summary

Constructors

Constructor and Description
ThreadedJobExecutor(Executor executor) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
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

Constructor Detail

ThreadedJobExecutor

public ThreadedJobExecutor(Executor executor)

Creates a new instance.

Parameters:

executor - thread manager

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

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