class Bundler::ParallelWorkers::UnixWorker

def stop_workers
  @workers.each do |worker|
    worker.io_r.close unless worker.io_r.closed?
    worker.io_w.close unless worker.io_w.closed?
    begin
      Process.kill :INT, worker.pid
    rescue Errno::ESRCH
      nil
    end
  end
  @workers.each do |worker|
    begin
      Process.waitpid worker.pid
    rescue Errno::ECHILD
      nil
    end
  end
end