class ActiveRecord::ConnectionAdapters::ConnectionPool::LeaseRegistry

def [](context)
  @mutex.synchronize do
    @map[context] ||= Lease.new
  end
end