| 10 | namespace anyflow { |
| 11 | |
| 12 | static void* execute_invoke_vertex(void* args) { |
| 13 | auto param = |
| 14 | reinterpret_cast<::std::tuple<GraphVertex*, GraphVertexClosure>*>(args); |
| 15 | auto vertex = ::std::get<0>(*param); |
| 16 | auto& closure = ::std::get<1>(*param); |
| 17 | vertex->run(::std::move(closure)); |
| 18 | delete param; |
| 19 | return NULL; |
| 20 | } |
| 21 | |
| 22 | static void* execute_invoke_closure(void* args) { |
| 23 | auto param = |