PaRSEC backend: offload reductions to dedicated task

When we encounter a streaming terminal we schedule a dedicated reducer task. Subsequent inputs are put into a LIFO. Once the reducer task runs it will process all available inputs for that terminal but will not block waiting for all inputs. In the worst case, we create N tasks (one for each input), likely less. Signed-off-by: Joseph Schuchart <[email protected]>
TESSEorg · Jun 5, 2023 · 35a1002 · 35a1002
1 parent 0433454
commit 35a1002
Show file tree

Hide file tree

Showing 2 changed files with 319 additions and 47 deletions.
diff --git a/tests/unit/fibonacci.cc b/tests/unit/fibonacci.cc
@@ -49,8 +49,9 @@ TEST_CASE("Fibonacci", "[fib][core]") {
               const auto F_n_plus_2 = F_n_plus_1 + F_n;
               ttg::sendv<1>(F_n_plus_1, outs);
               ttg::send<0>(F_n_plus_2, F_n_plus_1, outs);
-            } else
+            } else {
               ttg::finalize<1>(outs);
+            }
           },
           ttg::edges(F2F), ttg::edges(F2F, F2P));
       auto print_op = ttg::make_tt(