Class: Piggly::Util::ProcessQueue

Inherits:
Object
  • Object
show all
Defined in:
lib/piggly/util/process_queue.rb

Overview

Executes blocks in parallel subprocesses

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(concurrent = self.class.concurrent) ⇒ ProcessQueue

Returns a new instance of ProcessQueue.



17
18
19
 
# File 'lib/piggly/util/process_queue.rb', line 17

def initialize(concurrent = self.class.concurrent)
  @concurrent, @items = concurrent, []
end

Class Method Details

.concurrent ⇒ Object 



13
14
15
 
# File 'lib/piggly/util/process_queue.rb', line 13

def self.concurrent
  @concurrent || 1
end

.concurrent=(count) ⇒ Object 



9
10
11
 
# File 'lib/piggly/util/process_queue.rb', line 9

def self.concurrent=(count)
  @concurrent = count
end

Instance Method Details

#concurrent=(value) ⇒ Object 



21
22
23
 
# File 'lib/piggly/util/process_queue.rb', line 21

def concurrent=(value)
  @concurrent = value
end

#execute ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/piggly/util/process_queue.rb', line 35

def execute
  # Test if fork is supported
  forkable =
    begin
      Process.wait(Process.fork { exit! 60 })
      raise unless $?.exitstatus.to_i == 60
      true
    rescue Exception
      false
    end

  if forkable
    concurrently
  else
    serially
  end
end

#queue(&block) ⇒ Object Also known as: add 



29
30
31
 
# File 'lib/piggly/util/process_queue.rb', line 29

def queue(&block)
  @items << block
end

#size ⇒ Object 



25
26
27
 
# File 'lib/piggly/util/process_queue.rb', line 25

def size
  @items.size
end