RubyのThread、Fiber、Kernel、forkで並列処理やプロセスの深淵へ：若手エンジニア／初心者のためのRuby 2.1入門（11）（3/3 ページ）

» 2014年12月15日 18時00分公開

「Kernel.#fork」メソッドで別のプロセスとして処理を行わせる

　Kernelモジュールに定義されている「fork」メソッドを使うと、Rubyプログラムが自分自身の分身となるようなプロセスを生成して、別のプロセスとして処理を行わせることができます。

forkのメリット／デメリット

　冒頭で「並列化による高速化を狙ってThreadクラスを使うことは難しい」と書きましたが、「fork」を行うと、OSレベルで別のプロセスが生成されます。OSは各プロセスにCPUコアを振り分けているので、「fork」によって時間のかかる処理をうまく分散化できる可能性があります。また、「fork」されたプロセスは親プロセスと別の世界で動くというメリットもあります。

　ただし利点ばかりではありません。頻繁にforkすると、forkのためのオーバーヘッドが無視できなくなりますし、OSのシステムコールに依存する機能なので、forkシステムコールを持たないようなシステムでは利用することはできません。Windowsはforkシステムコールを持たないようですので、forkの恩恵にあずかることは残念ながらできません。

フォークする／しないの違いを調べるサンプルコード

　では、process03.rbとprocess04.rbに例を示しましょう。どちらも1億回（!）実数に「0.001」を足し込むような処理を行います。違いは、process03.rbはプロセスをフォークして実行しており、process04.rbはフォークせずに逐次実行している点です。

f = 0.0
started_time = Time.now.to_i
 
3.times do
  fork do
    100000000.times { f += 0.001 }
    printf("%.3f\n", f)
  end
end
 
Process.waitall
puts "it takes #{Time.now.to_i - started_time} s"

process03.rb

f = 0.0
started_time = Time.now.to_i
 
3.times do
  100000000.times { f += 0.001 }
  printf("%.3f\n", f)
  f = 0
end
 
puts "it takes #{Time.now.to_i - started_time} s"

process04.rb

$ ruby process03.rb 
100000.000
100000.000
100000.000
it takes 12 s

process03.rbの実行例

$ ruby process04.rb 
100000.000
100000.000
100000.000
it takes 26 s

process04.rbの実行例

コードの解説

　process03.rbもprocess04.rbも大筋は同じです。まず、1行目で変数fを0.0で初期化し、2行目で現在の時刻を取得し、それを「to_i」メソッドでUNIX時刻に変換して変数started_timeに格納します。

　続く4行目からの「3.times」とそのブロックで、process03.rbではプロセスを3回フォークしています。「fork」メソッドのブロック引数として、fに1億回「0.001」を足し込むような処理を与えています。process04.rbは、単に逐次的に1億回「0.001」を足し込むような処理を行っています。

　最後の行で、どちらのスクリプトも、現在のUNIX時刻と開始時のUNIX時刻の差を取り、処理時間を算出しています。

実行の様子

　「htop」というツールを使って、process03.rbとprocess04.rbの実行の様子を比べてみましょう。

process03.rbをhtopで見た様子

process04.rbをhtopで見た様子

　ご覧の通り、フォークした場合は「ruby process03.rb」というプロセスが3個立ち上がっていることが分かります。たいていの現代的なOSでは、CPUに負荷を掛けるようなプロセスはなるべく別々のCPUコアに割り当てるようにするので、process03.rbの方が処理時間も短く済んでいます。

　また、子プロセスはフォークされた時点で、それぞれメモリ空間などが異なる世界で動くことになります。ですので、process03.rbの6行目で変数fを書き換えても、他の子プロセスの変数fに影響することはないので、きちんといずれの子プロセスでも「100000.000」という計算結果が得られています。

次回はRubyの黒魔術「メタプログラミング」

　今回は、Rubyのスレッド、ファイバー、プロセスといった仕組みを学びました。特に、RubyのIOクラスやforkメソッドといった仕組みは、OSそのものと深くつながっています。

　例えばforkメソッドですが、UNIX系OSの標準的な「システムコール」の中に、ズバリ「フォーク」というものがあります。今回はあまり詳細に立ち入らずに説明したつもりですが、少し難しかったかもしれません。この辺りの話を深く理解するためにはOSの仕組みやシステムコールを学ぶ必要があるので、スキルアップのためにも、ぜひ勉強することをお勧めします。