Package com.kheops.jmap.server

Class JMapServerThreadPool

java.lang.Object

com.kheops.util.KObjectPool<JMapServerClientThread>

com.kheops.jmap.server.JMapServerThreadPool

All Implemented Interfaces:

KSchedulerClient

public class JMapServerThreadPool
extends KObjectPool<JMapServerClientThread>

Field Summary

Fields inherited from class com.kheops.util.KObjectPool

cleanupPeriod, recyclePeriod, shrinkTime, TIMEOUT_UNDEFINED, TIMEOUT_UNLIMITED

Constructor Summary

Constructors

Constructor	Description
JMapServerThreadPool(JMapServer server, int initialSize)

Method Summary

Modifier and Type	Method	Description
JMapServerClientThread	borrowThread()
JMapServerClientThread	borrowThread(long timeout, TimeUnit unit)
JMapServerClientThread	create()	Creates the object encapsulating the appropriate object
void	expire(JMapServerClientThread clientThread)	This method closes the object
void	returnThread(JMapServerClientThread clientThread)
boolean	validate(JMapServerClientThread clientThread)	This method checks if the object is valid

Methods inherited from class com.kheops.util.KObjectPool

apply, checkIn, checkOut, checkOut, close, createUnlockedInstance, getDefaultTimeout, getId, getMonitoringInfo, getPoolMaximumSize, getPoolSize, getPoolUsageCount, getPoolUsagePeak, getSystemDefaultTimeout, initialize, initialize, initialize, internalErrorOccurred, reset, resourceAdded, schCallback, setDefaultTimeout, setPoolMaximumSize, setPoolMinimumSize

Methods inherited from class java.lang.Object

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

Constructor Details

JMapServerThreadPool

public JMapServerThreadPool(JMapServer server,
 int initialSize)
                     throws Exception

Throws:

Exception

Method Details

validate

public boolean validate(JMapServerClientThread clientThread)

Description copied from class: KObjectPool

This method checks if the object is valid

Specified by:

validate in class KObjectPool<JMapServerClientThread>

Parameters:

clientThread - object to validate

Returns:

true if the object is valid false otherwise

expire

public void expire(JMapServerClientThread clientThread)

Description copied from class: KObjectPool

This method closes the object

Specified by:

expire in class KObjectPool<JMapServerClientThread>

Parameters:

clientThread - the object to be expired

create

public JMapServerClientThread create()

Description copied from class: KObjectPool

Creates the object encapsulating the appropriate object

Specified by:

create in class KObjectPool<JMapServerClientThread>

Returns:

the corresponding object

borrowThread

public JMapServerClientThread borrowThread()
                                    throws Exception

Throws:

Exception

borrowThread

public JMapServerClientThread borrowThread(long timeout,
 TimeUnit unit)
                                    throws Exception

Throws:

Exception

returnThread

public void returnThread(JMapServerClientThread clientThread)