Method ThreadFunc

library/cpp/netliba/v6/ib_mem.cpp:119–146

    }

    void* TIBMemPool::ThreadFunc(void* param) {
        BindToSocket(0);
        SetHighestThreadPriority();
        TIBMemPool* pThis = (TIBMemPool*)param;
        pThis->HasStarted.Signal();

        while (pThis->KeepRunning) {
            TJobItem* work = nullptr;
            if (!pThis->Requests.Dequeue(&work)) {
                pThis->HasWork.Reset();
                if (!pThis->Requests.Dequeue(&work)) {
                    pThis->HasWork.Wait();
                }
            }
            if (work) {
                //printf("mem copy got work\n");
                int sz = work->Data->GetSize();
                work->Block = pThis->Alloc(sz);
                TBlockChainIterator bc(work->Data->GetChain());
                bc.Read(work->Block->GetData(), sz);
                TIntrusivePtr<TCopyResultStorage> dst = work->ResultStorage;
                work->ResultStorage = nullptr;
                dst->Results.Enqueue(work);
                //printf("mem copy completed\n");
            }
        }
        return nullptr;
    }

    //////////////////////////////////////////////////////////////////////////
    static TMutex IBMemMutex;