com.adaptris.core.util

Class NonBlockingQuartzThreadPool

java.lang.Object

com.adaptris.core.util.NonBlockingQuartzThreadPool

All Implemented Interfaces:

org.quartz.spi.ThreadPool

public class NonBlockingQuartzThreadPool
extends java.lang.Object
implements org.quartz.spi.ThreadPool

A simple non-blocking ThreadPool implementation for use with Quartz.

QuartzCronPoller will default to using this implementation unless explictly configured not to via QuartzCronPoller.setUseCustomThreadPool(Boolean). Under the covers it uses a Executors.newScheduledThreadPool(int) as the thread execution pool. It does not need to block as polling consumers have an internal locking mechanism that handles that behaviour. The reason for using it is to ensure that ManagedThreadFactory is used to create any threads required for execution allowing a more graceful shutdown.

Constructor Summary

Constructors

Constructor and Description
NonBlockingQuartzThreadPool()

Method Summary

Modifier and Type	Method and Description
int	blockForAvailableThreads()
int	getPoolSize()
void	initialize()
boolean	runInThread(java.lang.Runnable runnable)
void	setInstanceId(java.lang.String schedInstId)
void	setInstanceName(java.lang.String schedName)
void	setMakeThreadsDaemons(boolean b) NoOp Method mirroring org.quartz.simpl.SimpleThreadPool#setMakeThreadsDaemons(boolean)
void	setThreadCount(int count)
void	setThreadNamePrefix(java.lang.String prfx) NoOp Method mirroring org.quartz.simpl.SimpleThreadPool#setThreadNamePrefix(String)
void	setThreadPriority(int prio) Setting that matches org.quartz.simpl.SimpleThreadPool#setThreadPriority(int)
void	setThreadsInheritContextClassLoaderOfInitializingThread(boolean inheritLoader) NoOp Method mirroring org.quartz.simpl.SimpleThreadPool#setThreadsInheritContextClassLoaderOfInitializingThread(boolean)
void	setThreadsInheritGroupOfInitializingThread(boolean inheritGroup) NoOp Method mirroring org.quartz.simpl.SimpleThreadPool#setThreadsInheritGroupOfInitializingThread(boolean)
void	shutdown(boolean waitForJobsToComplete)

Methods inherited from class java.lang.Object

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

Constructor Detail

NonBlockingQuartzThreadPool

public NonBlockingQuartzThreadPool()

Method Detail

blockForAvailableThreads

public int blockForAvailableThreads()

Specified by:

blockForAvailableThreads in interface org.quartz.spi.ThreadPool

setThreadCount

public void setThreadCount(int count)

setThreadPriority

public void setThreadPriority(int prio)

Setting that matches org.quartz.simpl.SimpleThreadPool#setThreadPriority(int)

initialize

public void initialize()
                throws org.quartz.SchedulerConfigException

Specified by:

initialize in interface org.quartz.spi.ThreadPool

Throws:

org.quartz.SchedulerConfigException

runInThread

public boolean runInThread(java.lang.Runnable runnable)

Specified by:

runInThread in interface org.quartz.spi.ThreadPool

shutdown

public void shutdown(boolean waitForJobsToComplete)

Specified by:

shutdown in interface org.quartz.spi.ThreadPool

getPoolSize

public int getPoolSize()

Specified by:

getPoolSize in interface org.quartz.spi.ThreadPool

setInstanceId

public void setInstanceId(java.lang.String schedInstId)

Specified by:

setInstanceId in interface org.quartz.spi.ThreadPool

setInstanceName

public void setInstanceName(java.lang.String schedName)

Specified by:

setInstanceName in interface org.quartz.spi.ThreadPool

setThreadNamePrefix

public void setThreadNamePrefix(java.lang.String prfx)

NoOp Method mirroring org.quartz.simpl.SimpleThreadPool#setThreadNamePrefix(String)

setThreadsInheritGroupOfInitializingThread

public void setThreadsInheritGroupOfInitializingThread(boolean inheritGroup)

NoOp Method mirroring org.quartz.simpl.SimpleThreadPool#setThreadsInheritGroupOfInitializingThread(boolean)

setThreadsInheritContextClassLoaderOfInitializingThread

public void setThreadsInheritContextClassLoaderOfInitializingThread(boolean inheritLoader)

NoOp Method mirroring org.quartz.simpl.SimpleThreadPool#setThreadsInheritContextClassLoaderOfInitializingThread(boolean)

setMakeThreadsDaemons

public void setMakeThreadsDaemons(boolean b)

NoOp Method mirroring org.quartz.simpl.SimpleThreadPool#setMakeThreadsDaemons(boolean)