com.goldencode.p2j.persist.orm

Class SessionFactory.SessionCloseThread

java.lang.Object

java.lang.Thread

com.goldencode.p2j.persist.orm.SessionFactory.SessionCloseThread

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

SessionFactory

public static class SessionFactory.SessionCloseThread
extends java.lang.Thread

A thread used to manage SessionFactory reclaimable sessions and close any sessions that have exceeded their lifespan.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private static java.util.Queue<SessionFactory>	factories A thread-safe queue that stores all SessionFactory instances created.
private static boolean	initialized Value used to check if the thread is initialized.
private static int	lifespan Lifespan of a thread (ms).

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
private	SessionCloseThread() Constructor that initializes the Queue and initializes the current thread as a Daemon thread.

Method Summary

Modifier and Type	Method and Description
static void	deregister(SessionFactory factory) Removes a SessionFactory instance from the queue.
static void	initialize() Creates an instance of the Thread and starts it.
private static void	register(SessionFactory factory) Add a SessionFactory instance to the queue managed by the thread.
private void	removeIdleSessions() Removes any sessions that have exceeded their lifespan from all existent factories.
void	run() The thread sleeps for the duration of a lifespan, then it calls the method for removing expired sessions.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

lifespan

private static int lifespan

Lifespan of a thread (ms). When it is exceeded, the session is closed.

factories

private static java.util.Queue<SessionFactory> factories

A thread-safe queue that stores all SessionFactory instances created.

initialized

private static boolean initialized

Value used to check if the thread is initialized.

Constructor Detail

SessionCloseThread

private SessionCloseThread()

Constructor that initializes the Queue and initializes the current thread as a Daemon thread.

Method Detail

initialize

public static void initialize()

Creates an instance of the Thread and starts it.

register

private static void register(SessionFactory factory)

Add a SessionFactory instance to the queue managed by the thread.

Parameters:

factory - A SessionFactory instance.

deregister

public static void deregister(SessionFactory factory)

Removes a SessionFactory instance from the queue. If the factory has a session that it's still active, it closes it.

Parameters:

factory - A SessionFactory instance.

run

public void run()

The thread sleeps for the duration of a lifespan, then it calls the method for removing expired sessions.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

removeIdleSessions

private void removeIdleSessions()

Removes any sessions that have exceeded their lifespan from all existent factories.