Method AcquireAsync

library/cpp/threading/future/async_semaphore.cpp:20–34

}

TFuture<TAsyncSemaphore::TPtr> TAsyncSemaphore::AcquireAsync() {
    with_lock(Lock_) {
        if (Cancelled_) {
            return MakeErrorFuture<TPtr>(
                std::make_exception_ptr(TOperationCancelledException()));
        }
        if (Count_) {
            --Count_;
            return MakeFuture<TAsyncSemaphore::TPtr>(this);
        }
        auto promise = NewPromise<TAsyncSemaphore::TPtr>();
        Promises_.push_back(promise);
        return promise.GetFuture();
    }
}

void TAsyncSemaphore::Release() {
    TPromise<TPtr> promise;