Pool Party is a Scala micro-library that turns a regular cats.effect.Resource into a non-blocking, fixed-size pooled resource with optional health checking and event reporting. This is pre-release software so it may cause your data center to burn down or (worse) not burn down. Either way it's not my problem.

Pool Party is published for Scala 2.13/3.0 and you can include it in your project thus:

libraryDependencies += "org.tpolecat" %% "pool-party" % <version>

PooledResourceBuilder builds a resource that yields a pooled version of some other underlying resource that you provide.

val r: Resource[F, Woozle] = ... // A limited resource

PooledResourceBuilder.of(r, 10).build.use { pool =>
  // `pool` has the same apparent behavior as `r`, but will never allow more than
  // 10 concurrent `Woozle`s, which will be recycled and reused on return.
}

In most cases you will create a pool when your program starts, and it will not be finalized until the program shuts down. In the common case for a web app your IOApp.run will look something like:

// A server is usually a resource you hang onto until someone hits ^C.
def run(args: List[String]): IO[ExitCode] =
  runResource[IO](args).use(_ => IO.never)

// That resource is the composition of many things, including our pool.
def runResource[F[_]: Temporal: OtherStuff](args: List[String]): Resource[F, ExitCode] =
  for {
    ...
    pool <- PoolBuilder.of(...).withHealthCheck(...).withReporter(...).build
    ...  <- httpServerResource(pool, etc) // request handler can say pool.use
  } yield ExitCode.Success

What you don't want to do is create a new pool for each request. It's a common error that defeats the purpose of pooling.

In addition to the pool size (required), PooledResourceBuilder provides the following configurable properties:

Note that the Reporter is invoked synchronously so it should not do anything time-consuming. A production reporter might enqueue events for later asynchronous processing.

First check out the Scaladoc, and if you're still in trouble please open an issue or find me on the Typelevel Discord.