org.mmbase.util

Class ThreadPools

java.lang.Object

org.mmbase.util.ThreadPools

public abstract class ThreadPools
extends Object

Generic MMBase Thread Pools

Since:

MMBase 1.8

Version:

$Id$

Author:

Michiel Meeuwissen

Field Summary

Fields

Modifier and Type	Field and Description
static ExecutorService	filterExecutor Generic Thread Pools which can be used by 'filters'.
static ThreadPoolExecutor	jobsExecutor All kind of jobs that should happen in a seperate Thread can be executed by this executor.
(package private) static UtilReader	properties
static ScheduledThreadPoolExecutor	scheduler This executor is for repeating tasks.
static ThreadGroup	threadGroup

Method Summary

Modifier and Type	Method and Description
(package private) static void	configure()
static String	getString(Future r) returns a identifier string for the given task.
static Map<String,ExecutorService>	getThreadPools()
static String	identify(Future r, String s) There is no way to identify the FutureTask objects returned in the getQueue methods of the executors.
static Thread	newThread(Runnable r, String id)
static ScheduledFuture	scheduleAtFixedRate(Runnable pub, int time1, int time2) Deprecated. Used ThreadPools.scheduler#scheduleAtFixedRate This method is only provided to use this in both 1.8 (concurrecy backport) and 1.9 (java 1.5).
protected static void	setProperty(ThreadPoolExecutor object, String key, String value)
static void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

threadGroup

public static final ThreadGroup threadGroup

filterExecutor

public static final ExecutorService filterExecutor

Generic Thread Pools which can be used by 'filters'. Filters are short living tasks. This is mainly used by ChainedCharTransformer (and only when transforming a Reader). Code performing a similar task could also use this thread pool.

jobsExecutor

public static final ThreadPoolExecutor jobsExecutor

All kind of jobs that should happen in a seperate Thread can be executed by this executor. E.g. sending mail could be done by a job of this type.

scheduler

public static final ScheduledThreadPoolExecutor scheduler

This executor is for repeating tasks. E.g. every running Module has a Module.maintainance() which is scheduled to run every hour.

Since:

MMBase-1.9

properties

static final UtilReader properties

Method Detail

identify

public static String identify(Future r,
                              String s)

There is no way to identify the FutureTask objects returned in the getQueue methods of the executors. This works around that. Used by admin pages.

Since:

MMBase-1.9

scheduleAtFixedRate

public static ScheduledFuture scheduleAtFixedRate(Runnable pub,
                                                  int time1,
                                                  int time2)

Deprecated. Used ThreadPools.scheduler#scheduleAtFixedRate This method is only provided to use this in both 1.8 (concurrecy backport) and 1.9 (java 1.5).

Wrapper around Thread.scheduler.scheduleAtFixedRate.

getString

public static String getString(Future r)

returns a identifier string for the given task.

Since:

MMBase-1.9

newThread

public static Thread newThread(Runnable r,
                               String id)

getThreadPools

public static Map<String,ExecutorService> getThreadPools()

setProperty

protected static void setProperty(ThreadPoolExecutor object,
                                  String key,
                                  String value)

Since:

MMBase-1.9.2

configure

static void configure()

Since:

MMBase-1.9

shutdown

public static void shutdown()

Since:

MMBase-1.8.4