Class: AccessStack

Inherits:
Object
  • Object
show all
Defined in:
lib/access_stack.rb,
lib/access_stack/version.rb

Constant Summary collapse

TimeoutError = 
Class.new StandardError
VERSION = 
"0.0.1"

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(opts = {}) ⇒ AccessStack

Returns a new instance of AccessStack.



11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/access_stack.rb', line 11

def initialize(opts={})
  @timeout = opts[:timeout] || opts["timeout"] || 5
  @size = opts[:size] || opts["size"] || 5
  @expires = opts[:expires] || opts["expires"] || -1
  @expr_hash = {}
  @stack = []
  @count = 0
  @mutex = Mutex.new
  @create = opts[:create] || opts["create"]
  @destroy = opts[:destroy] || opts["destroy"]
  @validate = opts[:validate] || opts["validate"]
end

Instance Attribute Details

#count ⇒ Object (readonly)

Returns the value of attribute count.



6
7
8
 
# File 'lib/access_stack.rb', line 6

def count
  @count
end

#create ⇒ Object

Returns the value of attribute create.



7
8
9
 
# File 'lib/access_stack.rb', line 7

def create
  @create
end

#destroy ⇒ Object

Returns the value of attribute destroy.



7
8
9
 
# File 'lib/access_stack.rb', line 7

def destroy
  @destroy
end

#expires ⇒ Object

Returns the value of attribute expires.



7
8
9
 
# File 'lib/access_stack.rb', line 7

def expires
  @expires
end

#size ⇒ Object

Returns the value of attribute size.



7
8
9
 
# File 'lib/access_stack.rb', line 7

def size
  @size
end

#timeout ⇒ Object

Returns the value of attribute timeout.



7
8
9
 
# File 'lib/access_stack.rb', line 7

def timeout
  @timeout
end

#validate ⇒ Object

Returns the value of attribute validate.



7
8
9
 
# File 'lib/access_stack.rb', line 7

def validate
  @validate
end

Instance Method Details

#create_objects(num = 1) ⇒ Object 



76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
 
# File 'lib/access_stack.rb', line 76

def create_objects(num=1)
  created_count = 0

  threadsafe do
    num.times do
      if @count < @size
        @stack.push create_obj
        @count += 1
        created_count += 1
      end
    end
  end
  
  created_count
end

#empty! ⇒ Object 



62
63
64
65
66
67
68
69
70
 
# File 'lib/access_stack.rb', line 62

def empty!
  return if @count == 0
  threadsafe do
    @stack.each(&@destroy.method(:call))
    @expr_hash.clear
    @stack.clear
    @count = 0
  end
end

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


92
93
94
 
# File 'lib/access_stack.rb', line 92

def empty?
  @count == 0
end

#fill ⇒ Object 



72
73
74
 
# File 'lib/access_stack.rb', line 72

def fill
  create_objects @count
end

#reap! ⇒ Object 



50
51
52
53
54
55
56
57
58
59
60
 
# File 'lib/access_stack.rb', line 50

def reap!
  return true if @count == 0
  threadsafe do
    @stack.reject(&method(:obj_valid)).each do |instance|
      @destroy.call instance
      @expr_hash.delete instance
      @stack.delete instance
      @count -= 1
    end
  end
end

#with(&block) ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/access_stack.rb', line 24

def with(&block)
  begin
    obj = nil
  
    threadsafe do
      obj = @stack.pop
    end
  
    if !(obj_valid obj)
      obj = nil
      @count -= 1
    end
  
    if @count < @size && obj.nil?
      @count += 1
      obj = create_obj
    end

    return block.call obj
  ensure
    threadsafe do
      @stack.push obj
    end
  end
end