Class: Concurrent::Supervisor::WorkerCounts

Inherits:
Struct
  • Object
show all
Defined in:
lib/concurrent/supervisor.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#specs ⇒ Object

Returns the value of attribute specs

Returns:

  • (Object) —

    the current value of specs



40
41
42
 
# File 'lib/concurrent/supervisor.rb', line 40

def specs
  @specs
end

#status ⇒ Object

Returns the value of attribute status.



41
42
43
 
# File 'lib/concurrent/supervisor.rb', line 41

def status
  @status
end

#supervisors ⇒ Object

Returns the value of attribute supervisors

Returns:

  • (Object) —

    the current value of supervisors



40
41
42
 
# File 'lib/concurrent/supervisor.rb', line 40

def supervisors
  @supervisors
end

#workers ⇒ Object

Returns the value of attribute workers

Returns:

  • (Object) —

    the current value of workers



40
41
42
 
# File 'lib/concurrent/supervisor.rb', line 40

def workers
  @workers
end

Instance Method Details

#abend ⇒ Object 



52
 
# File 'lib/concurrent/supervisor.rb', line 52

def abend() @status.reduce(0){|x, s| x += (s.nil? ? 1 : 0) } end

#aborting ⇒ Object 



50
 
# File 'lib/concurrent/supervisor.rb', line 50

def aborting() @status.reduce(0){|x, s| x += (s == 'aborting' ? 1 : 0) } end

#active ⇒ Object 



47
 
# File 'lib/concurrent/supervisor.rb', line 47

def active() sleeping + running + aborting end

#add(context) ⇒ Object 



42
43
44
45
46
 
# File 'lib/concurrent/supervisor.rb', line 42

def add(context)
  self.specs += 1
  self.supervisors += 1 if context.type == :supervisor
  self.workers += 1 if context.type == :worker
end

#running ⇒ Object 



49
 
# File 'lib/concurrent/supervisor.rb', line 49

def running() @status.reduce(0){|x, s| x += (s == 'run' ? 1 : 0) } end

#sleeping ⇒ Object 



48
 
# File 'lib/concurrent/supervisor.rb', line 48

def sleeping() @status.reduce(0){|x, s| x += (s == 'sleep' ? 1 : 0) } end

#stopped ⇒ Object 



51
 
# File 'lib/concurrent/supervisor.rb', line 51

def stopped() @status.reduce(0){|x, s| x += (s == false ? 1 : 0) } end