Method Release

library/cpp/threading/future/async_semaphore.cpp:36–51

}

void TAsyncSemaphore::Release() {
    TPromise<TPtr> promise;
    with_lock(Lock_) {
        if (Cancelled_) {
            return;
        }
        if (Promises_.empty()) {
            ++Count_;
            return;
        } else {
            promise = Promises_.front();
            Promises_.pop_front();
        }
    }
    promise.SetValue(this);
}

void TAsyncSemaphore::Cancel() {
    std::list<TPromise<TPtr>> promises;