Method run

example/use-with-bthread/bthread_graph_executor.cpp:42–54

}

int BthreadGraphExecutor::run(GraphVertex* vertex,
                              GraphVertexClosure&& closure) noexcept {
  bthread_t th;
  auto param = new ::std::tuple<GraphVertex*, GraphVertexClosure>(
      vertex, ::std::move(closure));
  if (0 != bthread_start_background(&th, NULL, execute_invoke_vertex, param)) {
    LOG(WARNING) << "start bthread to run vertex failed";
    closure = ::std::move(::std::get<1>(*param));
    delete param;
    return -1;
  }
  return 0;
}

int BthreadGraphExecutor::run(ClosureContext* closure,
                              Closure::Callback* callback) noexcept {