Method enqueueTask

include/tev/ThreadPool.h:48–71

    }

    template <std::invocable F> auto enqueueTask(F&& f, int priority, bool stopToken = false) {
        using return_type = std::invoke_result_t<F>;

        const auto task = std::make_shared<std::packaged_task<return_type()>>(std::forward<F>(f));
        auto res = task->get_future();

        if (mShuttingDown) {
            return res;
        }

        {
            const std::scoped_lock lock{mTaskQueueMutex};
            mTaskQueue.push({
                .fun = [task]() { (*task)(); },
                .priority = priority,
                .stopToken = stopToken,
            });
        }

        ++mNumTasksInSystem;
        mTaskQueueSemaphore.signal();

        return res;
    }

    auto enqueueStopToken() {
        return enqueueTask([] {}, std::numeric_limits<int>::max(), true);