Method check

modules/core/core/src/async/job.cpp:325–365

}

JobResult JobQueue::check() SKR_NOEXCEPT
{
    skr_rw_mutex_acquire_w(&pending_queue_mutex);
    SKR_DEFER({skr_rw_mutex_release_w(&pending_queue_mutex);});

    auto need_cancel = false;
    need_cancel = skr_atomic32_load_acquire(&cancel_requested);
    if (need_cancel)
    {
        std::for_each(pending_queue.begin(), pending_queue.end(), 
        [](auto ptr) {
            if (ptr->is_none() == false) 
            {
                ptr->cancel();
            }
        });
        skr_atomic32_store_release(&cancel_requested, false);
    }

    auto it = pending_queue.begin();
    while (it != pending_queue.end()) {
        // call finish() when finished
        if ((*it)->is_none()) {
            auto jobItemPtr = *it;
            // finish is called while the lock is released
            skr_rw_mutex_release_w(&pending_queue_mutex);
            jobItemPtr->finish(jobItemPtr->get_result());
            skr_rw_mutex_acquire_w(&pending_queue_mutex);

            // Since enqueue may be done while unlocking, it cannot be used
            // so re-search the list
            it = std::find(pending_queue.begin(), pending_queue.end(), jobItemPtr);
            it = pending_queue.erase(it);
        }
        else {
            ++it;
        }
    }

    return ASYNC_RESULT_OK;
}

void JobQueue::get_descriptor(JobQueueDesc* pDesc) SKR_NOEXCEPT
{