Method: Aerospike::Pool#poll

Defined in:
lib/aerospike/utils/pool.rb

#poll(create_new = true) ⇒ Object

[View source]

41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/aerospike/utils/pool.rb', line 41

def poll(create_new=true)
  non_block = true
  begin
    obj = @pool.pop(non_block)
    if !check(obj)
      cleanup(obj)
      obj = nil
    end
  end until obj
  obj
rescue ThreadError
  create if create_new
end