Fiberは「ノンプリエンプティブな軽量スレッド」とRubyのマニュアルに記載されています。
preemptiveは金融の用語のようです。 「先買いの、先買権のある」と辞書にありますが（ジーニアス英和辞典）、株式の売却時に優先的に買い取る権利を含む契約で、敵対勢力に株式を渡さないための方策だそうです。 このことについては、私は門外漢なので、正確な情報ではないことをお断りしておきます。 IT用語においては、「プリエンプティブ」はCPU時間を割り当てるときにOSが優先的にCPU時間を買取ってタスクに割り当てる、ということから使われるようになったのではないでしょうか。
さて、Fiberを使う場合、メインのプログラムとFiberのブロックの2つのタスクが動きます。 そして、プログラム中のresumeやyieldというメソッドがタスクの切り替えをします。 したがって、切り替えは完全にプログラムによってコントロールされており、その点でいつ切り替わるかはOS次第というプロセスとは異なります。 また、ここでいうタスクはRubyのThreadとは異なるので注意してください。
簡単なプログラム例
ファイバーの定義
ファイバーを定義するには、Fiber.newを使い、ファイバー自体はそのブロックに記述します。
fiber = Fiber.new do "abc".each_char do |c| print "#{c}\n" Fiber.yield end nil end
このブロックはメインプログラムの中で呼ばれるfiber.resumeメソッドによって実行されます。
- 最初に
fiber.resumeが呼ばれたとき、ブロックの最初からFiber.yeildまでが実行される Fiber.yieldの実行により、ブロックは一旦実行が止まり、メインルーチンのfiber.resumeの次からに実行が移る- 次に
fiber.resumeが呼ばれたときは、ブロックのFiber.yieldから実行され、再びFiber.yieldに達するか、ブロックの最後に達するまでそれが続く その後は実行はメインルーチンのfiber.resumeの次に移る - ブロックの最後まで達したファイバーは
field.resumeが呼ばれても実行できない。これはエラーになる
簡単なプログラム例
次の例は、メインとファイバーのブロックで交互にprint文を実行するメソッドです。
def example1 fiber = Fiber.new do "abc".each_char do |c| print "#{c}\n" Fiber.yield end nil end 101.upto(103) do |j| fiber.resume print "#{j}\n" end end # main example1
このプログラムの実行順を図にしました。
実行結果はつぎのようになります。
$ ruby _example/example39.rb a 101 b 102 c 103 $
ポイントは、Fiber.yieldとfiber.resumeで切り替わるところです。
ファイバーの使いどころ
ファイバーはどのようなプログラムに適しているのでしょうか？ ファイバーはコルーチンと呼ばれることもありますが、ウィキペディアのコルーチンでは、
サブルーチンと異なり、状態管理を意識せずに行えるため、協調的処理、イテレータ、無限リスト、パイプなど、継続状況を持つプログラムが容易に記述できる。
と書かれています。
ここでは、このうちイテレータとパイプについて考えてみたいと思います。 なお、ここでの記述については、誤りを含んでいるかもしれませんので、ご注意ください。 また、誤りにお気づきの方はコメントでご指摘いただければありがたいです。
イテレータ
イテレータというと、Rubyのeachメソッドを思い浮かべるのではないでしょうか。 eachメソッドは、そのオブジェクトの要素を取り出してブロック・パラメータに代入し、繰り返しブロックを実行します。 このような繰り返し処理を「イテレータ」といいます。 eachメソッドの方式は「内部イテレータ」といいます。
これに対して「外部イテレータ」というのがあります。Enumeratorクラスのnextメソッドはその例です。 nextメソッドは呼ばれるたびに「次のデータ」を返します。
def example2 a = [1,2,3].to_enum p a.next #=> 1 p a.next #=> 2 p a.next #=> 3 end example2
このプログラムでは配列[1,2,3]をto_enumメソッドでEnumeratorオブジェクトに変換しています。
Enumeratorオブジェクトのnextメソッドは呼ばれるたびに、1,2,3と順にその要素を返していきます。
ひとつのメソッド「next」が呼ばれるたびに異なる要素を返すので、これもイテレータと呼ばれるのです。
より正確には「外部イテレータ」です。
外部イテレータはFiberで簡単に実装できます。
def example3 fiber = Fiber.new do [1,2,3].each do |i| Fiber.yield(i) end end p fiber.resume p fiber.resume p fiber.resume end example3
Fiber.yieldに引数をつけると、その引数の値が対応するfiber.resumeの値になります。 これによって、ファイバーから外部にデータを渡すことができます。
この例では、ファイバー外部でresumeを呼ぶたびにファイバー内部のイテレータが繰り返し処理をするので、順に要素が返されます。
なお、Rubyのドキュメントに
Enumerator（の外部イテレータ）は Fiber を用いて実装されています。
と書かれています。
パイプ
パイプというのは、Bashなどのシェルプログラムで2つのプロセスをつなぎ、片方の出力を他方の入力につなげる機能です。 例えば
- cat: ファイルを読み込み、標準出力に書き出す
- wc: 文字数、単語数、行数などを計算して書き出す
をパイプ「|」で結びつけると、
$ cat example3.rb | wc
39 59 455
となり、ファイルexample3.rbは
- 行数が39
- 単語数が59（単語は空白や改行で区切られる文字列）
- 文字数が455
であることがわかります。 このとき
- catによってexample3.rbの内容が標準出力に送られ
- その出力はパイプ「
|」によって次のコマンドの標準入力に結び付けられ - それはwcによって行数、単語数、文字数として標準出力に出力される
ということになります。
一般にあるプロセスの出力をバッファに保存し、それを別のプロセスの入力につなげる問題を「生産者ー消費者問題」といいます。 並行動作するプロセスでこれを行う場合、セマフォを使って実現します。 セマフォは一般に短いプログラムで、セマフォの実行中は他のタスクに切り替わらないことが保証されています。
ファイバーを使う場合は、タスクが切り替えのタイミングを決められるのでセマフォは不要で、プログラムも簡単になります。 また、消費者側をメインにし生産者側をファイバーにする「消費者起動方式」が理解しやすいです。
catとwcに相当するプログラムをFiberで作ってみましょう。 ただし、単純化するためwc部分は行数のみをカウントすることにします。
def example4 filename fiber = Fiber.new do File.open(filename) do |file| while (s = file.gets) Fiber.yield(s) end end nil end nline = 0 while fiber.resume nline +=1 end print "#{nline}\n" end example4("example39.rb")
ファイバー側はファイルをオープン後、一行入力してはyieldします。
EOFになるとfile.getsはnilを返すのでwhileループが終了します。
ですから、最後にfiber.resumeで呼ばれたときは、whileループを脱出するのでFiber.yieldは実行されません。
そのときにはFiber.newのブロックの値（ブロックの最後に評価された値）がfiber.resumeの値として返されます。
すなわち、nilが返ります。
メインルーチンはfiber.resumeの値をチェックして真（この場合は文字列が返っている）ならばnlineをカウントアップします。
最後にnilが返ってきてwhileループを抜け、nlineの値をプリントします。
ファイバーとメソッド
ファイバーはイテレータやパイプなどを分かりやすく表現することができるのですが、同様のことはインスタンス変数とメソッドで実現することができます。 そのため、あまりファイバーは使われないのが実情ではないでしょうか。
しかし、最後の例のようなファイルをオープンするケースをメソッドで実装する場合、オープンとクローズは別メソッドで行うのが多いです。 つまり、オープン、一行読込、クローズの3つのメソッドを用いることになります。 Fiberは、その中でオープン、クローズも行えるので一つで済み、実装が簡単です。
ファイバーは他の言語ではコルーチンと呼ばれることもあります。 例えば、Luaではコルーチンと呼んでいます。 ネットでもファイバーよりもコルーチンで検索するほうが多くの情報にヒットします。
