info.pppc.base.system.operation

Class OperationPool

java.lang.Object

info.pppc.base.system.operation.OperationPool

All Implemented Interfaces:

IOperator

public class OperationPool
extends java.lang.Object
implements IOperator

The operation pool can be used to limit the number of threads created by the system to some fixed value. It can also be used to control the default number of threads that will be created and kept for future calls. This can be used to increase the performance of systems that execute a large number of short running operations.

Author:

Marcus Handte

Constructor Summary

Constructors

Constructor and Description
OperationPool(int defaultThreads) Creates an operation pool with an unlimited number of threads and the specified number of default threads.
OperationPool(int defaultThreads, int maximumThreads) Creates an operation pool with the specified number of default threads that will be hold even if no operations must be executed and the specified number of maximum threads.

Method Summary

Methods

Modifier and Type	Method and Description
void	performOperation(IOperation operation) Executes the specified operation using a default monitor.
void	performOperation(IOperation operation, IMonitor monitor) Executes the specified operation using the specified monitor.
void	shutdown() Performs a shutdown on the pool.

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationPool

public OperationPool(int defaultThreads)

Creates an operation pool with an unlimited number of threads and the specified number of default threads. The number of threads shrinks to the number of default threads when ever a thread finishes.

Parameters:

defaultThreads - The default number of threads that will be kept, set to 0 to remove all threads after an operation has been executed.

Throws:

java.lang.IllegalArgumentException - Thrown if the default number of threads is negative.

OperationPool

public OperationPool(int defaultThreads,
             int maximumThreads)

Creates an operation pool with the specified number of default threads that will be hold even if no operations must be executed and the specified number of maximum threads. If maximum threads is set to 0, the threads will not be limited.

Parameters:

defaultThreads - The number of threads that will be kept even if no operations need to be executed, set to 0 to remove all threads after they have been created.

maximumThreads - The number of threads that will be created. Set to 0 to allow an unlimited number of new threads.

Throws:

java.lang.IllegalArgumentException - Thrown if the default number or the maximum number of threads is negative.

Method Detail

performOperation

public void performOperation(IOperation operation)

Executes the specified operation using a default monitor.

Specified by:

performOperation in interface IOperator

Parameters:

operation - The operation to execute.

performOperation

public void performOperation(IOperation operation,
                    IMonitor monitor)

Executes the specified operation using the specified monitor.

Specified by:

performOperation in interface IOperator

Parameters:

operation - The operation to execute.

monitor - The monitor used by the operation.

shutdown

public void shutdown()

Performs a shutdown on the pool. If the pool is shutdown future operations will still be performed, however, the pool semantics will change as each thread will be shutdown as soon as no more operations are available.