org.apache.nifi.engine

Class FlowEngine

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

org.apache.nifi.engine.FlowEngine

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService, java.util.concurrent.ScheduledExecutorService

public final class FlowEngine
extends java.util.concurrent.ScheduledThreadPoolExecutor

Nested Class Summary

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

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
FlowEngine(int corePoolSize, java.lang.String threadNamePrefix) Creates a new instance of FlowEngine
FlowEngine(int corePoolSize, java.lang.String threadNamePrefix, boolean daemon) Creates a new instance of FlowEngine

Method Summary

Modifier and Type	Method and Description
protected void	afterExecute(java.lang.Runnable runnable, java.lang.Throwable throwable) Hook method called by the thread that executed the given runnable after execution of the runnable completed.
protected void	beforeExecute(java.lang.Thread thread, java.lang.Runnable runnable) Hook method called by the running thread whenever a runnable task is given to the thread to run.
protected void	terminated() Hook method called whenever the engine is terminated.

Methods inherited from class java.util.concurrent.ScheduledThreadPoolExecutor

decorateTask, decorateTask, execute, getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy, shutdown, shutdownNow, submit, submit, submit

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

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

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Constructor Detail

FlowEngine

public FlowEngine(int corePoolSize,
                  java.lang.String threadNamePrefix)

Creates a new instance of FlowEngine

Parameters:

corePoolSize - the maximum number of threads available to tasks running in the engine.

threadNamePrefix - for naming the thread

FlowEngine

public FlowEngine(int corePoolSize,
                  java.lang.String threadNamePrefix,
                  boolean daemon)

Creates a new instance of FlowEngine

Parameters:

corePoolSize - the maximum number of threads available to tasks running in the engine.

threadNamePrefix - for thread naming

daemon - if true, the thread pool will be populated with daemon threads, otherwise the threads will not be marked as daemon.

Method Detail

beforeExecute

protected void beforeExecute(java.lang.Thread thread,
                             java.lang.Runnable runnable)

Hook method called by the running thread whenever a runnable task is given to the thread to run.

Overrides:

beforeExecute in class java.util.concurrent.ThreadPoolExecutor

Parameters:

thread - thread

runnable - runnable

afterExecute

protected void afterExecute(java.lang.Runnable runnable,
                            java.lang.Throwable throwable)

Hook method called by the thread that executed the given runnable after execution of the runnable completed. Logs the fact of completion and any errors that might have occurred.

Overrides:

afterExecute in class java.util.concurrent.ThreadPoolExecutor

Parameters:

runnable - runnable

throwable - throwable

terminated

protected void terminated()

Hook method called whenever the engine is terminated.

Overrides:

terminated in class java.util.concurrent.ThreadPoolExecutor