Method Decrease

oneflow/core/common/blocking_counter.cpp:31–36

}

int64_t BlockingCounter::Decrease() {
  std::unique_lock<std::mutex> lck(mtx_);
  cnt_val_ -= 1;
  if (cnt_val_ == 0) { cond_.notify_all(); }
  return cnt_val_;
}

Maybe<void> BlockingCounter::WaitUntilCntEqualZero(size_t timeout_seconds) {
  return Singleton<ForeignLockHelper>::Get()->WithScopedRelease([&, this]() -> Maybe<void> {