Method LockRecursive

util/generic/singleton.cpp:45–57

}

void NPrivate::LockRecursive(std::atomic<size_t>& lock) noexcept {
    const size_t id = MyThreadId();

    Y_ABORT_UNLESS(lock.load(std::memory_order_acquire) != id, "recursive singleton initialization");

    if (!MyAtomicTryLock(lock, id)) {
        TSpinWait sw;

        do {
            sw.Sleep();
        } while (!MyAtomicTryAndTryLock(lock, id));
    }
}

void NPrivate::UnlockRecursive(std::atomic<size_t>& lock) noexcept {
    Y_ABORT_UNLESS(lock.load(std::memory_order_acquire) == MyThreadId(), "unlock from another thread?!?!");