Function WorkerLoop

oneflow/core/vm/virtual_machine.cpp:70–81

}

void WorkerLoop(vm::ThreadCtx* thread_ctx, const std::function<void(vm::ThreadCtx*)>& Initializer) {
  SyncVmModeGuard guard(SyncVmMode::kEnable);
  Initializer(thread_ctx);
  constexpr static size_t kExpireMicroseconds = 200;
  while (thread_ctx->mut_notifier()->WaitAndClearNotifiedCnt() == kNotifierStatusSuccess) {
    std::chrono::time_point<std::chrono::steady_clock> start{};
    do {
      while (thread_ctx->TryReceiveAndRun()) { start = std::chrono::steady_clock::now(); }
      std::this_thread::yield();
    } while (MicrosecondsFrom(start) < kExpireMicroseconds);
  }
}

}  // namespace