com.mongodb.util

Class ThreadPool<T>

java.lang.Object

com.mongodb.util.ThreadPool<T>

Deprecated.

This class is no longer in use and should not have been public. It may be removed in a future release.

@Deprecated
public abstract class ThreadPool<T>
extends java.lang.Object

A thread pool implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	ThreadPool.MyThread Deprecated.
(package private) class	ThreadPool.MyThreadGroup Deprecated.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicInteger	_inProgress Deprecated.
(package private) int	_maxThreads Deprecated.
private ThreadPool.MyThreadGroup	_myThreadGroup Deprecated.
(package private) java.lang.String	_name Deprecated.
private java.util.concurrent.BlockingQueue<T>	_queue Deprecated.
private java.util.List<ThreadPool.MyThread>	_threads Deprecated.

Constructor Summary

Constructors

Constructor and Description
ThreadPool(java.lang.String name, int numThreads) Deprecated. Initializes a new thread pool with a given name and number of threads.
ThreadPool(java.lang.String name, int numThreads, int maxQueueSize) Deprecated. Initializes a new thread pool with a given name, number of threads, and queue size.

Method Summary

Modifier and Type	Method and Description
abstract void	handle(T t) Deprecated. Handles a given object.
abstract void	handleError(T t, java.lang.Exception e) Deprecated. Handles a given object and exception.
int	inProgress() Deprecated.
int	numThreads() Deprecated.
boolean	offer(T t) Deprecated. Adds a new object to the pool, if possible.
int	queueSize() Deprecated. Returns the size of the pool's queue.

Methods inherited from class java.lang.Object

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

Field Detail

_name

final java.lang.String _name

Deprecated.

_maxThreads

final int _maxThreads

Deprecated.

_inProgress

private final java.util.concurrent.atomic.AtomicInteger _inProgress

Deprecated.

_threads

private final java.util.List<ThreadPool.MyThread> _threads

Deprecated.

_queue

private final java.util.concurrent.BlockingQueue<T> _queue

Deprecated.

_myThreadGroup

private final ThreadPool.MyThreadGroup _myThreadGroup

Deprecated.

Constructor Detail

ThreadPool

public ThreadPool(java.lang.String name,
                  int numThreads)

Deprecated.

Initializes a new thread pool with a given name and number of threads.

Parameters:

name - identifying name

numThreads - the number of threads allowed in the pool

ThreadPool

public ThreadPool(java.lang.String name,
                  int numThreads,
                  int maxQueueSize)

Deprecated.

Initializes a new thread pool with a given name, number of threads, and queue size.

Parameters:

name - identifying name

numThreads - the number of threads allowed in the pool

maxQueueSize - the size of the pool entry queue

Method Detail

handle

public abstract void handle(T t)
                     throws java.lang.Exception

Deprecated.

Handles a given object.

Parameters:

t - the object to handle

Throws:

java.lang.Exception

handleError

public abstract void handleError(T t,
                                 java.lang.Exception e)

Deprecated.

Handles a given object and exception.

Parameters:

t - the object to handle

e - the exception to handle

queueSize

public int queueSize()

Deprecated.

Returns the size of the pool's queue.

Returns:

pool size

offer

public boolean offer(T t)

Deprecated.

Adds a new object to the pool, if possible.

Parameters:

t - the object to be added

Returns:

if the object was successfully added

inProgress

public int inProgress()

Deprecated.

numThreads

public int numThreads()

Deprecated.