cascading.management

Class UnitOfWorkExecutorStrategy

java.lang.Object

cascading.management.UnitOfWorkExecutorStrategy

All Implemented Interfaces:

UnitOfWorkSpawnStrategy

public class UnitOfWorkExecutorStrategy
extends java.lang.Object
implements UnitOfWorkSpawnStrategy

Class UnitOfWorkExecutorStrategy uses a simple Executors.newFixedThreadPool(int) ExecutorService to spawn threads.

This is the default spawn strategy.

Constructor Summary

Constructors

Constructor and Description
UnitOfWorkExecutorStrategy()

Method Summary

Methods

Modifier and Type	Method and Description
void	complete(UnitOfWork unitOfWork, int duration, java.util.concurrent.TimeUnit unit)
boolean	isCompleted(UnitOfWork unitOfWork)
java.util.List<java.util.concurrent.Future<java.lang.Throwable>>	start(UnitOfWork unitOfWork, int maxConcurrentThreads, java.util.Collection<java.util.concurrent.Callable<java.lang.Throwable>> values)

Methods inherited from class java.lang.Object

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

Constructor Detail

UnitOfWorkExecutorStrategy

public UnitOfWorkExecutorStrategy()

Method Detail

start

public java.util.List<java.util.concurrent.Future<java.lang.Throwable>> start(UnitOfWork unitOfWork,
                                                                     int maxConcurrentThreads,
                                                                     java.util.Collection<java.util.concurrent.Callable<java.lang.Throwable>> values)
                                                                       throws java.lang.InterruptedException

Specified by:

start in interface UnitOfWorkSpawnStrategy

Throws:

java.lang.InterruptedException

isCompleted

public boolean isCompleted(UnitOfWork unitOfWork)

Specified by:

isCompleted in interface UnitOfWorkSpawnStrategy

complete

public void complete(UnitOfWork unitOfWork,
            int duration,
            java.util.concurrent.TimeUnit unit)
              throws java.lang.InterruptedException

Specified by:

complete in interface UnitOfWorkSpawnStrategy

Throws:

java.lang.InterruptedException