cb_connect.rb

require 'rubygems'
require 'couchbase'
 
CONFIG = {
	:node_list => ["localhost:8091"],
	:key_prefix => "pool_",
	:pool_size => 3
}

def connection(bucket)
  @servers ||= {}
  @servers[bucket] ||= begin
                         size = CONFIG[:pool_size]
                         params = CONFIG.merge(:bucket => bucket)
                         Couchbase::ConnectionPool.new(size, params)
                       end
end

connection("bucket1").set('foo', 'bar')
connection("bucket2").set('bar', 'foo')
 
threads = []
5.times do
  threads << Thread.new do
    connection("bucket1").get('foo')
    connection("bucket2").get('bar')
  end
end
 
threads.map do |t|
  puts [t.object_id, t.value].join("\t")
end