Class: Teapot::Commands::Pool

Inherits:
Object
  • Object
show all
Defined in:
lib/teapot/commands.rb

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ Pool

Returns a new instance of Pool.



74
75
76
77
78
79
 
# File 'lib/teapot/commands.rb', line 74

def initialize(options = {})
  @commands = []
  @limit = options[:limit] || Commands.processor_count
  
  @running = Set.new
end

Instance Method Details

#run(*args) ⇒ Object 



81
82
83
84
85
86
87
 
# File 'lib/teapot/commands.rb', line 81

def run(*args)
  args = args.flatten.collect &:to_s
  
  @commands << args
  
  schedule!
end

#schedule! ⇒ Object 



89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
 
# File 'lib/teapot/commands.rb', line 89

def schedule!
  while @running.size < @limit and @commands.size > 0
    command = @commands.shift
    
    puts command.join(' ').color(:blue)
    
    pid = Process.fork do
      exec(*command)
      
      exit!(0)
    end
    
    @running << pid
  end
end

#wait ⇒ Object 



105
106
107
108
109
110
111
112
 
# File 'lib/teapot/commands.rb', line 105

def wait
  while @running.size > 0
    pid = Process.wait(0)
    @running.delete(pid)
    
    schedule!
  end
end