Method finalize

modules/core/core/src/async/job.cpp:276–300

}

int JobQueue::finalize() SKR_NOEXCEPT
{
    // Queue as many JobFinalizeItems as the number of worker threads to finish the worker threads.
    // Since the worker thread that received JobFinalizeItem will always end without taking the next Job,
    // This will terminate all worker threads.
    skr::stl_vector<JobFinalizeItem> finalJobs;
    finalJobs.reserve(thread_list.size());
    for (int i = 0; i < thread_list.size(); ++i)
    {
        finalJobs.emplace_back();
        enqueueCore(&finalJobs.back(), /*isEndJob=*/true); // Normal enqueue will fail after this point
    }

    // wait for worker thread to finish。
    for (auto *pWorkerThread : thread_list)
    {
        pWorkerThread->join();

        SkrDelete(pWorkerThread->get_function());
        SkrDelete(pWorkerThread);
    }
    thread_list.clear();

    return ASYNC_RESULT_OK;
}

int JobQueue::enqueue(JobItem* jobItem) SKR_NOEXCEPT
{