Package net.quasardb.qdb

Class SessionPool

java.lang.Object

net.quasardb.qdb.SessionPool

public class SessionPool
extends Object

Session / connection pool. This class is thread-safe. Simple, fixed-size pool where sessions are pre-allocated in the constructor.

Constructor Summary

Constructors

Constructor	Description
SessionPool(SessionFactory factory, int size)

Method Summary

Modifier and Type	Method	Description
Session	acquire()	Take a session from the pool.
void	close()	Close the pool and all sessions associated with it.
void	release(Session s)	Release a session back to the pool.
int	size()	Returns the amount of sessions currently on the pool.

Methods inherited from class java.lang.Object

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

Constructor Details

SessionPool

public SessionPool(SessionFactory factory,
 int size)

Parameters:

factory - SessionFactory instance used to create new sessions.

size - Amount of sessions to pre-allocate.

Method Details

acquire

public Session acquire()
                throws InterruptedException,
IOException

Take a session from the pool. May block if no sessions are available.

Throws:

InterruptedException

IOException

release

public void release(Session s)
             throws InterruptedException

Release a session back to the pool.

Parameters:

s - Session previously acquired from the pool

Throws:

InterruptedException

size

public int size()

Returns the amount of sessions currently on the pool.

close

public void close()
           throws IOException

Close the pool and all sessions associated with it. Should *not* be called when there are still sessions that are not released back to the pool yet.

Throws:

IOException