Class: Lipsiadmin::Loops::WorkerPool

Inherits:
Object
  • Object
show all
Defined in:
lib/loops/worker_pool.rb

Overview

:nodoc:

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name, logger, engine, &blk) ⇒ WorkerPool

Returns a new instance of WorkerPool.



7
8
9
10
11
12
13
14
 
# File 'lib/loops/worker_pool.rb', line 7

def initialize(name, logger, engine, &blk)
  @name = name
  @logger = logger
  @worker_block = blk
  @shutdown = false
  @engine = engine
  @workers = []
end

Instance Attribute Details

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



4
5
6
 
# File 'lib/loops/worker_pool.rb', line 4

def logger
  @logger
end

#name ⇒ Object (readonly)

Returns the value of attribute name.



5
6
7
 
# File 'lib/loops/worker_pool.rb', line 5

def name
  @name
end

Instance Method Details

#check_workers ⇒ Object 



23
24
25
26
27
28
29
30
 
# File 'lib/loops/worker_pool.rb', line 23

def check_workers
  logger.debug("Checking loop #{name} workers...")
  @workers.each do |worker|
    next if worker.running? || worker.shutdown?
    logger.debug("Worker #{worker.name} is not running. Restart!")
    worker.run
  end
end

#start_workers(number) ⇒ Object 



16
17
18
19
20
21
 
# File 'lib/loops/worker_pool.rb', line 16

def start_workers(number)
  logger.debug("Creating #{number} workers for #{name} loop...")
  number.times do
    @workers << Lipsiadmin::Loops::Worker.new(name, logger, @engine, &@worker_block)
  end
end

#stop_workers(force) ⇒ Object 



42
43
44
45
46
47
48
49
50
 
# File 'lib/loops/worker_pool.rb', line 42

def stop_workers(force)
  return if @shutdown
  @shutdown = false
  logger.debug("Stopping loop #{name} workers...")
  @workers.each do |worker|
    next unless worker.running?
    worker.stop(force)
  end
end

#wait_workers ⇒ Object 



32
33
34
35
36
37
38
39
40
 
# File 'lib/loops/worker_pool.rb', line 32

def wait_workers
  running = 0
  @workers.each do |worker|
    next unless worker.running?
    running += 1
    logger.debug("Worker #{name} is still running (#{worker.pid})")
  end
  return running
end