com.serotonin.mango.rt.maint

Class BackgroundProcessing

java.lang.Object

com.serotonin.mango.rt.maint.BackgroundProcessing

All Implemented Interfaces:

com.serotonin.util.ILifecycle

public class BackgroundProcessing
extends java.lang.Object
implements com.serotonin.util.ILifecycle

A cheesy name for a class, i know, but it pretty much says it like it is. This class keeps an inbox of items to process, and oddly enough, processes them. (Oh, and removes them from the inbox when it's done.)

Author:

Matthew Lohbihler

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	JOB_GROUP
static java.lang.String	JOB_NAME
(package private) org.apache.commons.logging.Log	log
private java.util.concurrent.ExecutorService	lowPriorityService
private java.util.concurrent.ThreadPoolExecutor	mediumPriorityService

Constructor Summary

Constructors

Constructor and Description
BackgroundProcessing()

Method Summary

Modifier and Type	Method and Description
void	addWorkItem(WorkItem item)
int	getMediumPriorityServiceQueueSize()
void	initialize()
void	joinTermination()
void	terminate()

Methods inherited from class java.lang.Object

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

Field Detail

JOB_NAME

public static final java.lang.String JOB_NAME

JOB_GROUP

public static final java.lang.String JOB_GROUP

See Also:

Constant Field Values

log

final org.apache.commons.logging.Log log

mediumPriorityService

private java.util.concurrent.ThreadPoolExecutor mediumPriorityService

lowPriorityService

private java.util.concurrent.ExecutorService lowPriorityService

Constructor Detail

BackgroundProcessing

public BackgroundProcessing()

Method Detail

addWorkItem

public void addWorkItem(WorkItem item)

getMediumPriorityServiceQueueSize

public int getMediumPriorityServiceQueueSize()

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

joinTermination

public void joinTermination()

Specified by:

joinTermination in interface com.serotonin.util.ILifecycle