| 27 | namespace euler { |
| 28 | |
| 29 | Executor::Executor(DAG* dag, ThreadPool* thread_pool, OpKernelContext* ctx) |
| 30 | : dag_(dag), thread_pool_(thread_pool), ctx_(ctx), |
| 31 | ref_(dag->num_nodes()), remain_node_(dag->num_nodes()) { |
| 32 | for (auto& node : dag->nodes()) { |
| 33 | ref_[node->id()] = node->num_inputs(); |
| 34 | } |
| 35 | } |
| 36 | |
| 37 | void Executor::Run() { |
| 38 | Signal sig; |
nothing calls this directly
no test coverage detected