Kouhei Sutou
null+****@clear*****
Thu Jul 17 22:23:41 JST 2014
Kouhei Sutou 2014-07-17 22:23:41 +0900 (Thu, 17 Jul 2014) New Revision: df9117f9c3e5b6019462d97f1e1ec9af488a812f https://github.com/droonga/wikipedia-search/commit/df9117f9c3e5b6019462d97f1e1ec9af488a812f Message: Stop parallel Modified files: lib/wikipedia-search/task.rb Modified: lib/wikipedia-search/task.rb (+11 -6) =================================================================== --- lib/wikipedia-search/task.rb 2014-07-17 21:40:23 +0900 (3b6cc64) +++ lib/wikipedia-search/task.rb 2014-07-17 22:23:41 +0900 (e7fd54a) @@ -186,9 +186,7 @@ module WikipediaSearch "--report-throughput", @path.droonga.pages.to_s) ensure - pids.each do |pid| - stop_process(pid) - end + stop_processes(pids) end end @@ -207,9 +205,7 @@ module WikipediaSearch droonga_wait_engine_ready(front_node_id) $stdin.gets ensure - pids.each do |pid| - stop_process(pid) - end + stop_processes(pids) end end end @@ -277,6 +273,15 @@ module WikipediaSearch end end + def stop_processes(pids) + stop_threads = pids.collect do |pid| + Thread.new do + stop_process(pid) + end + end + stop_threads.each(&:join) + end + def stop_process(pid) Process.kill(:TERM, pid) Process.waitpid(pid) -------------- next part -------------- HTML����������������������������...下載
