Class: Helper::AsyncCommand

Inherits:

Object

• Object
• Helper::AsyncCommand

Defined in:

lib/helper.rb

Overview

外部コマンド実行中の待機ループの処理を書けるクラス

返り値：[標準出力のキャプチャ, 標準エラーのキャプチャ, Process::Status]

response = Helper::AsyncCommand.exec(“処理に時間がかかる外部コマンド”) do

print "*"

end if response.success?

puts "成功しました"

end

Class Method Summary

• .exec(command, sleep_time = 0.5, &block) ⇒ Object

Class Method Details

.exec(command, sleep_time = 0.5, &block) ⇒ Object

# File 'lib/helper.rb', line 322

def self.exec(command, sleep_time = 0.5, &block)
  looper = nil
  _pid = nil
  status, stdout, stderr = systemu(command) do |pid|
    _pid = pid
    looper = Thread.new(pid) do |pid|
      loop do
        block.call if block
        sleep(sleep_time)
        if Narou::Worker.canceled?
          Process.kill("KILL", pid)
          Process.detach(pid)
          break
        end
      end
    end
    looper.join
    looper = nil
  end
  stdout.force_encoding(Encoding::UTF_8)
  stderr.force_encoding(Encoding::UTF_8)
  return [stdout, stderr, status]
rescue Interrupt
  if _pid
    begin
      Process.kill("KILL", _pid)
      Process.detach(_pid)    # 死亡確認しないとゾンビ化する
    rescue
    end
  end
  raise
ensure
  looper.kill if looper
end