Class: Async::HTTP::Pool

Inherits:
Object
  • Object
show all
Defined in:
lib/async/http/pool.rb

Overview

Pool behaviours

  • Single request per connection (HTTP/1 without keep-alive)

  • Multiple sequential requests per connection (HTTP1 with keep-alive)

  • Multiplex requests per connection (HTTP2)

In general we don’t know the policy until connection is established.

This pool doesn’t impose a maximum number of open resources, but it WILL block if there are no available resources and trying to allocate another one fails.

Resources must respond to #multiplex -> 1 or more. #reusable? -> can be used again.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(limit = nil, &block) ⇒ Pool

Returns a new instance of Pool.



38
39
40
41
42
43
44
45
 
# File 'lib/async/http/pool.rb', line 38

def initialize(limit = nil, &block)
  @available = {} # resource => count
  @waiting = []
  
  @limit = limit
  
  @constructor = block
end

Instance Attribute Details

#available ⇒ Object (readonly)

Returns the value of attribute available.



47
48
49
 
# File 'lib/async/http/pool.rb', line 47

def available
  @available
end

Instance Method Details

#acquire ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
 
# File 'lib/async/http/pool.rb', line 53

def acquire
  resource = wait_for_next_available
  
  return resource unless block_given?
  
  begin
    yield resource
  ensure
    release(resource)
  end
end

#close ⇒ Object 



75
76
77
78
 
# File 'lib/async/http/pool.rb', line 75

def close
  @available.each_key(&:close)
  @available.clear
end

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


49
50
51
 
# File 'lib/async/http/pool.rb', line 49

def empty?
  @available.empty?
end

#release(resource) ⇒ Object

Make the resource available and let waiting tasks know that there is something available.



66
67
68
69
70
71
72
73
 
# File 'lib/async/http/pool.rb', line 66

def release(resource)
  # A resource that is not good should also not be reusable.
  if resource.reusable?
    reuse(resource)
  else
    retire(resource)
  end
end