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 collapse
Class Method Details
.exec(command, sleep_time = 0.5, &block) ⇒ Object
369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 |
# File 'lib/helper.rb', line 369 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 |