trait Pool[A <: AnyRef] extends AnyRef
A pool of objects that may be leased. It is expected that all implementations of this trait are thread-safe.
- A
the type of object to pool
- Alphabetic
- By Inheritance
- Pool
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def capacity(): Int
Returns the capacity of the pool, i.e.
Returns the capacity of the pool, i.e. the maximum number of objects the pool can hold.
- returns
the capacity of the pool.
- abstract def dispose(a: A): Unit
Object "destructor".
Object "destructor". This method is called whenever the object is evicted from the pool. For example, when doing connection pooling it is necessary to close the connection whenever it is evicted (i.e. permanently removed) from the pool.
- Attributes
- protected
- abstract def factory(): A
Factory method for creating new objects.
Factory method for creating new objects.
- returns
a new object.
- Attributes
- protected
- abstract def handleAcquire(): Lease[A]
- Attributes
- protected
- abstract def handleClose(): Unit
- Attributes
- protected
- abstract def handleDrain(): Unit
- Attributes
- protected
- abstract def handleFill(): Unit
- Attributes
- protected
- abstract def handleTryAcquire(atMost: Duration): Option[Lease[A]]
- Attributes
- protected
- abstract def handleTryAcquire(): Option[Lease[A]]
- Attributes
- protected
- abstract def healthCheck(a: A): Boolean
An health check that is performed on an object before its leased from the pool.
An health check that is performed on an object before its leased from the pool. If the health check passes the object is successfully leased. Otherwise, the object is destroyed (and a new one is fetched or created)
- Attributes
- protected
- abstract def live(): Int
Returns the number of live objects, i.e.
Returns the number of live objects, i.e. the number of currently pooled objects plus leased objects.
The value returned by this method is only accurate when the
referenceType
is io.github.andrebeat.pool.ReferenceType.Strong, since GC-based eviction is checked only when trying to acquire an object.- returns
the number of live objects.
- abstract def referenceType: ReferenceType
Returns the io.github.andrebeat.pool.ReferenceType of the objects stored in the pool.
- abstract def reset(a: A): Unit
Resets the internal state of object.
Resets the internal state of object. This method is called on an object whenever it is added/released back to the pool. For example, if pooling an object like a java.nio.ByteBuffer it might make sense to call its
reset()
method whenever the object is released to the pool, so that its future users do not observe the internal state introduced by previous ones.- Attributes
- protected
- abstract def size(): Int
Returns the number of objects in the pool.
Returns the number of objects in the pool.
The value returned by this method is only accurate when the
referenceType
is io.github.andrebeat.pool.ReferenceType.Strong, since GC-based eviction is checked only when trying to acquire an object.- returns
the number of objects in the pool.
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def acquire(): Lease[A]
Acquire a lease for an object blocking if none is available.
Acquire a lease for an object blocking if none is available.
- returns
a lease for an object from this pool.
- Exceptions thrown
ClosedPoolException
If this pool is closed.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def close(): Unit
Closes this pool, and properly disposes of each pooled object, releasing any resources associated with the pool (e.g.
Closes this pool, and properly disposes of each pooled object, releasing any resources associated with the pool (e.g. background timer threads).
If the pool has already been closed this method does nothing.
- val closed: AtomicBoolean
- Attributes
- protected[this]
- def drain(): Unit
Drains the object pool, i.e.
Drains the object pool, i.e. evicts every object currently pooled.
- Exceptions thrown
ClosedPoolException
If this pool is closed.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def fill(): Unit
Fills the object pool by creating (and pooling) new objects until the number of live objects reaches the pool capacity.
Fills the object pool by creating (and pooling) new objects until the number of live objects reaches the pool capacity.
- Exceptions thrown
ClosedPoolException
If this pool is closed.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def leased(): Int
Returns the number of leased objects.
Returns the number of leased objects.
The value returned by this method is only accurate when the
referenceType
is io.github.andrebeat.pool.ReferenceType.Strong, since GC-based eviction is checked only when trying to acquire an object.- returns
the number of leased objects.
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def tryAcquire(atMost: Duration): Option[Lease[A]]
Try to acquire a lease for an object blocking at most until the given duration.
Try to acquire a lease for an object blocking at most until the given duration.
- atMost
maximum wait time for the lease to be available.
- returns
a lease for an object from this pool if available until the given duration,
None
otherwise.
- Exceptions thrown
ClosedPoolException
If this pool is closed.
- def tryAcquire(): Option[Lease[A]]
Try to acquire a lease for an object without blocking.
Try to acquire a lease for an object without blocking.
- returns
a lease for an object from this pool if available,
None
otherwise.
- Exceptions thrown
ClosedPoolException
If this pool is closed.
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)