Packages

•  package root

  Definition Classes

  root

•  package io

  Definition Classes

  root

•  package github

  Definition Classes

  io

•  package andrebeat

  Definition Classes

  github

•  package pool

  This library provides classes for dealing with object pooling that allow:

  This library provides classes for dealing with object pooling that allow:

  • blocking/non-blocking object acquisition
  • object invalidation
  • capping the number of pooled objects
  • creating new objects lazily, as needed
  • health checking
  • time-based pool eviction (idle instances)
  • GC-based pool eviction (soft and weak references)
  • efficient thread-safety

  Overview

  In order create a new io.github.andrebeat.pool.Pool the constructor method should be used like so

  scala> val pool = Pool(4, () => new Object)
  pool: io.github.andrebeat.pool.SimplePool[Object] = _
  scala> val lease = pool.acquire()
  lease: io.github.andrebeat.pool.Lease[Object] = _
  scala> lease.release()

  Additionally, in order to avoid manually releasing the lease after its used, you can use the use method on the lease:

  scala> val pool = Pool(4, () => new Object)
  pool: io.github.andrebeat.pool.SimplePool[Object] = _
  scala> val lease = pool.acquire()
  lease: io.github.andrebeat.pool.Lease[Object] = _
  scala> lease(println) // the lease is released automatically after its used
  java.lang.Object@7970d6d

  Definition Classes

  andrebeat

•  abstract class ArrayBlockingQueuePool[A <: AnyRef] extends Pool[A]

  A generic object pooling implementation based on java.util.concurrent.ArrayBlockingQueue.

  A generic object pooling implementation based on java.util.concurrent.ArrayBlockingQueue. This implementation relies on the thread-safety and blocking/non-blocking mechanisms of the underlying data structure to implement the pool interface. Furthermore, for synchronization and tracking of live instances an java.util.concurrent.atomic.AtomicInteger is used. No locks are used in this implementation.

  The type of items inserted in the queue must implement the Item interface. This class defines methods for consuming the item (e.g. disposing of any resources associated with it) and a method that's called whenever an item is successfully inserted into the queue (useful for triggering a side-effect). This class is also responsible for dealing with the reference type that's wrapping the value (i.e. ensure calling its destructor if the value is defined).

  Definition Classes

  pool

• Item

io.github.andrebeat.pool.ArrayBlockingQueuePool

Item