Function enqueue

modules/core/task/src/task2.cpp:416–449

    

    void enqueue(Task&& task, int workerIdx)
    {
        //SkrZoneScopedN("EnqueueTask");
        scheduler_t* scheduler = scheduler_t::instance();
        SKR_ASSERT(scheduler != nullptr);
        size_t workerCount = scheduler->config.numThreads;
        while(true)
        {
            int idx = 0;
            if(workerIdx < 0)
            {
                auto i = --scheduler->nextSpinningWorkerIdx % scheduler->spinningWorkers.size();
                idx = scheduler->spinningWorkers[i].exchange(-1);
                if(idx < 0)
                    idx = scheduler->nextEnqueueIndex++ % (workerCount - 1) + 1;
            }
            else 
            {
                SKR_ASSERT((uint32_t)workerIdx < workerCount);
                idx = workerIdx;
            }
            auto& worker = *(Worker*)scheduler->workers[idx];
            if(workerIdx < 0)
            {
                worker.enqueue(std::move(task), false);
                return;
            }
            else if(skr_mutex_try_acquire(&worker.work.mutex))
            {
                worker.enqueuePinnedAndUnlock(std::move(task));
                return;
            }
        }
    }

    void scheduler_t::schedule(skr::stl_function<void ()>&& function)
    {