Lines Matching refs:combiner

15 class combiner {
24 combiner.run(do_stuff)
27 If you have two threads calling combiner, there will be some kind of
28 queuing in place. It's called `combiner` because you can pass in more
38 * This means that `do_stuff` doesn't necessarily run to completion when `combiner.run` is invoked
41 class combiner {
56 The basic idea is that the first one to push onto the combiner
58 until the combiner is drained.
60 Our combiner does some additional work, with the motivation of write-batching.
66 item, we might put something onto the main combiner queue and so we'll
69 …puts that into a finally. That way anything else that gets put into the combiner can add to that w…
72 class combiner {
75 …ue finally; // you can only do run_finally when you are already running something from the combiner
108 The above combiner has the problem that it keeps draining for a
125 (distributor) wakeup FD. The work-queue is the converse of the combiner; it