Method Add

library/cpp/threading/equeue/equeue.cpp:48–67

bool TElasticQueue::Add(IObjectInQueue* obj) {
    if (!TryIncCounter()) {
        return false;
    }

    THolder<TDecrementingWrapper> wrapper;
    try {
        wrapper.Reset(new TDecrementingWrapper(obj, this));
    } catch (...) {
        AtomicDecrement(GuardCount_);
        throw;
    }

    if (SlaveQueue_->Add(wrapper.Get())) {
        Y_UNUSED(wrapper.Release());
        return true;
    } else {
        return false;
    }
}

void TElasticQueue::Start(size_t threadCount, size_t maxQueueSize) {
    MaxQueueSize_ = maxQueueSize;