Shard Detail

pool v0.2.3

Generic (connection) pools

Install & Use

Add the following code to your project's shard.yml under:

dependencies to use in production
- OR -
development_dependencies to use in development

  github: ysbaddaden/pool



Generic (connection) pools for Crystal

Getting Started

A pool tailored for sharing connections across coroutines.

Connections will be checkout from the pool and tied to the current fiber, until they are checkin, and thus be usable by another coroutine. Otherwise they behave the same than the generic pool.

require "pg"
require "pool/connection"

pg = 25, timeout: 0.01) do

You may checkout as many connections in parallel as needed, then checkin the connections as required:

conn = pg.checkout
result = conn.exec("SELECT * FROM posts")

You may checkout a single connection per coroutine. Trying to checkout another one will always return the same single connection:

conn = pg.connection
result = conn.exec("SELECT * FROM posts")

You may also use a block, so the connection will be checkin back into the pool, unless the connection was already checkout, in which case it will be passed to the block, but not returned to the pool:

pg.connection do |conn|
  result = conn.exec("SELECT * FROM posts")


Licensed under the Apache License, Version 2.0