Method push

modules/core/core/src/async/job.cpp:47–73

    }

    JobResult push(JobItem* jobItem, bool isEndJob = false)
    {
        cond->lock();
        const auto endJobEnqueud = skr_atomic32_load_acquire(&is_end_job_queued);
        if (endJobEnqueud && !isEndJob)
        {
            cond->unlock();
            return ASYNC_RESULT_ERROR_INVALID_STATE;
        }

        // update the status of JobItem together with the state of the queue
        skr_atomic32_store_release(&jobItem->status, isEndJob ? kJobItemStatusFinishJob : kJobItemStatusWaiting);
        list_runnable.emplace_back(jobItem);

        // end job is queued, only end job is accepted
        skr_atomic32_store_release(&is_end_job_queued, isEndJob);

        const auto c = skr_atomic32_load_acquire(&waiting_workers_count);
        if (c) 
        {
            cond->signal();
        }

        cond->unlock();

        return ASYNC_RESULT_OK;
    }

    void erase(JobItem* jobItem)
    {