gene_pool
Description:
Highly performant Ruby connection pooling library.
Features:
- Thread-safe
- Pure ruby
Installation:
gem install gene_pool
Example Usage:
class MyClient
# Print a logger warning if it requires more than 0.25 seconds to acquire a connection.
# Close and reopen the connection if it hasn't been used for 10 seconds.
# Raise Timeout::Error if waiting for a connection more than 3 seconds.
@gene_pool = GenePool.new(
name: 'MyClient',
pool_size: 10,
timeout: 3,
warn_timeout: 0.25,
idle_timeout: 10,
logger: Rails.logger,
close_proc: :close) do
TCPSocket.new('myserver', 4321)
end
def send_message
@gene_pool.with_connection do |socket|
begin
# use socket here
rescue Exception => e
# If the socket gets closed, remove it from the pool
@gene_pool.remove(socket)
end
end
end
# Equivalent to send_message above
def send_message_auto_remove
# On exception, close and remeove socket from pool
@gene_pool.with_connection_auto_remove do |socket|
# use socket here,
end
end
def send_message_auto_retry
# On exception, close and reopen socket and perform retry
@gene_pool.with_connection_auto_retry do |socket|
# use socket here,
end
end
end
Copyright
Copyright (c) 2010-2012 Brad Pardee. See LICENSE for details.