Method LaunchWorker

preempt/src/xqueue/launch_worker.cpp:7–22

using namespace xsched::preempt;

LaunchWorker::LaunchWorker(std::shared_ptr<HwQueue> hwq, std::shared_ptr<CommandBuffer> buf,
                           XPreemptLevel level, int64_t threshold, int64_t batch_size)
    : level_(level), threshold_(threshold), batch_size_(batch_size)
    , kHwq(hwq), kCmdBuf(buf), mtx_(std::make_unique<MCSLock>())
{
    // In-flight commands threshold must not be smaller than command batch size.
    // Otherwise, there could be no commands to wait if the in-flight commands reach the threshold.
    XASSERT(threshold_ >= batch_size_, "threshold must not be smaller than command batch size");

    worker_thread_ = std::make_unique<std::thread>([this](){
        // Notify the HwQueue that an XQueue has created for it on the submitting thread.
        // It can call platform specific APIs like cuCtxSetCurrent() in OnXQueueCreate().
        this->kHwq->OnXQueueCreate();
        this->WorkerLoop();
    });
}

LaunchWorker::~LaunchWorker()
{