fs2.Pull#compile 勉強会 その4

今回やりたいこと

CEK 機械は…

call-by-value (「値呼び」と訳されることがある)、つまり、「関数の引数を評価しきってからβ簡約する」ような実行方式

引数よりも先に関数側を評価する

組み込みオペレータ呼び出しに関しては、「左から右」に引数を評価していく

この機械をどう実装したかというと、

機械の状態として、次の二つのモノの組を持つ

そのクロージャを仮に評価し切れたら、そのとき何をしなければならないか

「まな板の上に置かれた」クロージャの評価を進められそうならそうしていき、その際に未評価の部分を一旦脇に置いておく必要があるときには、「戻ってきたときにその未評価の部分についてどうこうする」という情報を継続側に積む

「まな板の上に置かれた」クロージャが値になっていたら (それ以上評価できなくなっていたら)、継続の一番最初の部分を切り崩し、値を用いて「次に評価しなければならないクロージャ」を作る

今回の旅のしおり

とりあえず、メモリバリアについては無視します

索引

code:Scala

// 「各 K/V pair の間で型が合ってる」ような Map (Map を使う限り型システムに載らない情報なので、こういう型になってる)

// ↑ではなかった。↑の例だと全部のペアでAに大統一されてしまう

// 今 Fiber が実行に使っている ExecutionContext (最初は startEC)

/*

* Ideally these would be on the stack, but they can't because we sometimes need to

* relocate our runloop to another fiber.

*/

// conts と objectState は結託して継続を保存している

// objectState は継続の引数を保存している

// OnCancel 時に finalizer を積む場所

// 「今、もしこの瞬間にキャンセルされたら、どの finalizer を (どの順番で) 実行しないといけなかったのか」を保存している

// 実際にキャンセルされた時には、この Stack の上から順に finalizer を実行していく

// Fiber が終了したときに呼ぶべきコールバックを覚えておく場所

// _join (この Fiber を外側から見ている観測者にとっては、「終わったら通知してくれ」というリクエスト) を完了させるために使う

// windy: フードコートで渡される鳴るやつを思い出した

// Fiber が前回の run (「飽きるまで走ったとき」)の最後に何をしていたかを記録する 1 Byte

// Fiber が前回の run の最後に何を _cur0 の余剰として遺したのかを記録する

// Work-stealing thread pool と blocking (unbounded) thread pool の組とか、どれぐらいの頻度で「飽きる」のかとかの、

// Fiber のいわゆる設定情報

// Tracing 機能を実現するための、trace を入れたリングバッファ (デフォルトで size = 16; IORuntimeConfig.DefaultTraceBufferSize)

// なぜ stack じゃなくて ringbuffer なのか、というと、例えば tailRecM とかで「意味的には」コールスタックをどんどん深めていくような場合でも

// メモリを無限に食われると困るので、過去 (tailRecM をするよりも前) のトレースを犠牲にしてでもメモリ使用量を抑えるため

if (TracingConstants.isStackTracing) RingBuffer.empty(runtime.traceBufferLogSize) else null

// 自分はキャンセルされたか？

// Uncancelable がいくつ重なっているか？

// 終了処理の真っ只中か？

// この Fiber の最終結果で、最初は null

@volatile