org.opencms.scheduler

类 CmsSchedulerThreadPool

java.lang.Object

org.opencms.scheduler.CmsSchedulerThreadPool

所有已实现的接口:

org.quartz.spi.ThreadPool

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

Simple thread pool used for the Quartz scheduler in OpenCms.

从以下版本开始:

6.0.0

构造器概要

构造器

构造器和说明
CmsSchedulerThreadPool() Create a new CmsSchedulerThreadPool with default values.
CmsSchedulerThreadPool(int initialThreadCount, int maxThreadCount, int threadPriority) Create a new CmsSchedulerThreadPool with the specified number of threads that have the given priority.

方法概要

方法

限定符和类型	方法和说明
int	blockForAvailableThreads()
protected java.lang.Runnable	getNextRunnable() Dequeue the next pending Runnable.
int	getPoolSize()
int	getThreadPriority() Returns the thread priority of the threads in the scheduler pool.
void	initialize()
boolean	runInThread(java.lang.Runnable runnable) Run the given Runnable object in the next available Thread.
void	shutdown() Terminate any worker threads in this thread group.
void	shutdown(boolean waitForJobsToComplete) Terminate all threads in this thread group.

从类继承的方法 java.lang.Object

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

构造器详细资料

CmsSchedulerThreadPool

public CmsSchedulerThreadPool()

Create a new CmsSchedulerThreadPool with default values. This will create a pool with 0 initial and 10 maximum threads running in normal priority.

另请参阅:

CmsSchedulerThreadPool(int, int, int)

CmsSchedulerThreadPool

public CmsSchedulerThreadPool(int initialThreadCount,
                      int maxThreadCount,
                      int threadPriority)

Create a new CmsSchedulerThreadPool with the specified number of threads that have the given priority. The OpenCms scheduler thread pool will initially start with provided number of active scheduler threads. When a thread is requested by the scheduler, and no "free" threads are available, a new thread will be added to the pool and used for execution. The pool will be allowed to grow until it has reached the configured number of maximum threads.

参数:

initialThreadCount - the initial number of threads for the pool

maxThreadCount - maximum number of threads the pool is allowed to grow

threadPriority - the thread priority for the scheduler threads

另请参阅:

Thread

方法详细资料

blockForAvailableThreads

public int blockForAvailableThreads()

返回:

if the pool should be blocked for available threads

另请参阅:

ThreadPool

getPoolSize

public int getPoolSize()

指定者:

getPoolSize 在接口中 org.quartz.spi.ThreadPool

另请参阅:

ThreadPool.getPoolSize()

getThreadPriority

public int getThreadPriority()

Returns the thread priority of the threads in the scheduler pool.

返回:

the thread priority of the threads in the scheduler pool

initialize

public void initialize()
                throws org.quartz.SchedulerConfigException

指定者:

initialize 在接口中 org.quartz.spi.ThreadPool

抛出:

org.quartz.SchedulerConfigException

另请参阅:

ThreadPool.initialize()

runInThread

public boolean runInThread(java.lang.Runnable runnable)

Run the given Runnable object in the next available Thread.

If while waiting the thread pool is asked to shut down, the Runnable is executed immediately within a new additional thread.

指定者:

runInThread 在接口中 org.quartz.spi.ThreadPool

参数:

runnable - the Runnable to run

返回:

true if the Runnable was run

shutdown

public void shutdown()

Terminate any worker threads in this thread group.

Jobs currently in progress will be allowed to complete.

shutdown

public void shutdown(boolean waitForJobsToComplete)

Terminate all threads in this thread group.

指定者:

shutdown 在接口中 org.quartz.spi.ThreadPool

参数:

waitForJobsToComplete - if true,, all current jobs will be allowed to complete

getNextRunnable

protected java.lang.Runnable getNextRunnable()
                                      throws java.lang.InterruptedException

Dequeue the next pending Runnable.

返回:

the next pending Runnable

抛出:

java.lang.InterruptedException - if something goes wrong