Class: FloorManager::Workers

Inherits:
Object
  • Object
show all
Defined in:
lib/floormanager/workers.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(*queue) ⇒ Workers

Returns a new instance of Workers.



4
5
6
7
8
 
# File 'lib/floormanager/workers.rb', line 4

def initialize(*queue)
  queue = *queue
  @queue = queue.kind_of?(FloorManager::Queue) ? queue : FloorManager::Queue.new(queue)
  @mutex = Mutex.new
end

Instance Attribute Details

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



9
10
11
 
# File 'lib/floormanager/workers.rb', line 9

def queue
  @queue
end

Instance Method Details

#checkin(*args) ⇒ Object 



39
40
41
 
# File 'lib/floormanager/workers.rb', line 39

def checkin(*args)
  synchronize{@queue.checkin(*args)}
end

#checkout ⇒ Object 



35
36
37
 
# File 'lib/floormanager/workers.rb', line 35

def checkout
  synchronize{@queue.checkout}
end

#failed(result = nil) ⇒ Object 



60
61
62
 
# File 'lib/floormanager/workers.rb', line 60

def failed(result=nil)
  result(result, States::FAILED)
end

#halt(time) ⇒ Object 



48
49
50
 
# File 'lib/floormanager/workers.rb', line 48

def halt(time)
  synchronize{sleep(time)}
end

#perform(options = {}) ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/floormanager/workers.rb', line 11

def perform(options={})
  options = {:threads => 1, :timeout => false}.merge(options)
  threads = (0...options[:threads]).to_a.map do |thread_id|
    Thread.new do
      until queue.done?
        if item = checkout
          result = yield(item[:item])
          result = Result.new(result, (result.state rescue States::SUCCESS))
          item[:value] = result
          checkin(item, result.state)
        else
          Thread.pass
        end
      end
    end
  end
  if options[:timeout]
    threads.each{|t| t.join(options[:timeout])}
  else
    threads.each{|t| t.join}
  end
  @queue
end

#result(result, state = States::SUCCESS) ⇒ Object 



52
53
54
 
# File 'lib/floormanager/workers.rb', line 52

def result(result, state=States::SUCCESS)
  Result.new(result, state)
end

#success(result) ⇒ Object 



56
57
58
 
# File 'lib/floormanager/workers.rb', line 56

def success(result)
  result(result, States::SUCCESS)
end

#synchronize ⇒ Object Also known as: exclusively 



43
44
45
 
# File 'lib/floormanager/workers.rb', line 43

def synchronize
  @mutex.synchronize{yield}
end