com.github.geko444.im4java.process

Class ProcessExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

com.github.geko444.im4java.process.ProcessExecutor

All Implemented Interfaces:

ProcessEventListener, Executor, ExecutorService

Direct Known Subclasses:

BatchConverter

public class ProcessExecutor
extends ThreadPoolExecutor
implements ProcessEventListener

This class subclasses ThreadPoolExecutor and implements a pooling-service for threads running processes.

Since:

1.1.0

Version:

$Revision: 1.3 $

Author:

$Author: bablokb $

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
ProcessExecutor() The default constructor creates a fixed-sized thread-pool with corePoolSize == maximumPoolSize.
ProcessExecutor(int pProcs) Create a ProcessExecutor with given number of threads for corePoolSize and maximumPoolSize.

Method Summary

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t) Deregister this ProcessExecutor as a ProcessEventListener.
protected void	beforeExecute(Thread t, Runnable r) Register this ProcessExecutor as a ProcessEventListener.
void	destroy() Destroy all active processes.
void	processInitiated(ProcessEvent pEvent) This method is called at process initiation.
void	processStarted(ProcessEvent pEvent) This method is called at process startup.
void	processTerminated(ProcessEvent pEvent) This method is called at normal or abnormal process termination.
List<Runnable>	shutdownNow()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessExecutor

public ProcessExecutor()

The default constructor creates a fixed-sized thread-pool with corePoolSize == maximumPoolSize. The maximum number of concurrently running processes is controlled by the system-property im4java.maxProcs. If unset or if the property has the value auto, the number returned by Runtime.availableProcessors() is used.

ProcessExecutor

public ProcessExecutor(int pProcs)

Create a ProcessExecutor with given number of threads for corePoolSize and maximumPoolSize.

Parameters:

pProcs - Number of concurrently executing processes.

Method Detail

beforeExecute

protected void beforeExecute(Thread t,
                             Runnable r)

Register this ProcessExecutor as a ProcessEventListener.

Overrides:

beforeExecute in class ThreadPoolExecutor

afterExecute

protected void afterExecute(Runnable r,
                            Throwable t)

Deregister this ProcessExecutor as a ProcessEventListener.

Overrides:

afterExecute in class ThreadPoolExecutor

processInitiated

public void processInitiated(ProcessEvent pEvent)

This method is called at process initiation.

Specified by:

processInitiated in interface ProcessEventListener

processStarted

public void processStarted(ProcessEvent pEvent)

This method is called at process startup. This method is called at process startup. We keep track of processes so we can destroy them if necessary.

Specified by:

processStarted in interface ProcessEventListener

processTerminated

public void processTerminated(ProcessEvent pEvent)

This method is called at normal or abnormal process termination. This method is called at normal or abnormal process termination.

Specified by:

processTerminated in interface ProcessEventListener

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

Overrides:

shutdownNow in class ThreadPoolExecutor

destroy

public void destroy()

Destroy all active processes.