Class: Forked::ProcessManager

Inherits:
Object
  • Object
show all
Defined in:
lib/forked/process_manager.rb

Constant Summary collapse

ON_ERROR = 
-> (e, tries) { }

Instance Method Summary collapse

Constructor Details

#initialize(process_timeout: 5, logger: Logger.new(STDOUT)) ⇒ ProcessManager

Returns a new instance of ProcessManager.



8
9
10
11
12
 
# File 'lib/forked/process_manager.rb', line 8

def initialize(process_timeout: 5, logger: Logger.new(STDOUT))
  @process_timeout = process_timeout
  @workers = {}
  @logger = logger
end

Instance Method Details

#fork(name = nil, retry_strategy: ::Forked::RetryStrategies::ExponentialBackoff, retry_backoff_limit: nil, on_error: ON_ERROR, &block) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
 
# File 'lib/forked/process_manager.rb', line 14

def fork(name = nil, retry_strategy: ::Forked::RetryStrategies::ExponentialBackoff, retry_backoff_limit: nil, on_error: ON_ERROR, &block)
  worker = Worker.new(
    name: name,
    retry_strategy: retry_strategy,
    retry_backoff_limit: retry_backoff_limit,
    on_error: on_error,
    block: block,
  )
  fork_worker(worker)
end

#shutdown ⇒ Object 



31
32
33
34
35
36
37
 
# File 'lib/forked/process_manager.rb', line 31

def shutdown
  @logger.info "Master shutting down"
  send_signal_to_workers(:TERM)
  wait_for_workers_until_timeout
  send_signal_to_workers(:KILL)
  @logger.info "Master shutdown complete"
end

#wait_for_shutdown ⇒ Object 



25
26
27
28
29
 
# File 'lib/forked/process_manager.rb', line 25

def wait_for_shutdown
  trap_shutdown_signals
  handle_child_processes
  shutdown
end

#worker_pids ⇒ Object 



39
40
41
 
# File 'lib/forked/process_manager.rb', line 39

def worker_pids
  @workers.keys
end