Installation

libraryDependencies+="io.github.andrebeat"%%"scala-pool"%"0.5.0"

libraryDependencies+="io.github.andrebeat"%%"scala-pool"%"0.5.1-SNAPSHOT"

resolvers+=Resolver.sonatypeRepo("snapshots")

Usage

importio.github.andrebeat.pool._// Creating a `Pool[Object]` with a capacity of 2 instancesvalpool=Pool(2, ()=>newObject)// Acquiring a lease on an object from the pool (blocking if none available)vallease= pool.acquire()// Using the leaselease { o=>  println(o)}// The object is returned to the pool at this point

Pool(capacity:Int,// the maximum capacity of the poolfactory: ()=>A,// the function used to create new objects in the poolreferenceType:ReferenceType,// the reference type of objects in the poolmaxIdleTime:Duration,// the maximum amount of the time that objects are allowed//   to idle in the pool before being evictedreset:A=>Unit,// the function used to reset objects in the pool//   (called when leasing an object from the pool)dispose:A=>Unit,// the function used to destroy an object from the poolhealthCheck:A=>Boolean)// the predicate used to test whether an object is//   healthy and should be used, or destroyed otherwise

importio.github.andrebeat.pool._// Creating a `Pool[Object]` with a capacity of 2 instancesvalpool=Pool(2, ()=>newObject)// Getting the value from the leasevalobj= lease.get()// There are currently no objects on the poolpool.size// res0: Int = 0// But its capacity is 2 (objects are created lazily)pool.capacity// res1: Int = 2// There's 1 live objectpool.live// res2: Int = 1// And its currently leasedpool.leased// res3: Int = 1// Releasing our lease back to the poollease.release// Its now in the pool waiting to be reusedpool.size// res4: Int = 1// Closes this pool, properly disposing of each pooled object and// releasing any resources associated with the poolpool.close()

License