在 C++ 中扩展 Job/Worker 多线程系统

Question

我一直在阅读 Ben Hoffman (https://benhoffman.tech/cpp/general/2018/11/13/cpp-job-system.html)

的教程

我尝试过将他拥有的 Job/Worker 系统的一个版本拼凑在一起，但我没有使用 void* 作为参数然后转换为已知结构，而是一直在尝试使用可变参数。这个想法是，一个作业接受一个 "parent" 来执行一个方法，函数指针指向所述方法，以及一个 Args... 作为参数。但是，如果我尝试构建，则会出现内部编译器错误。这是作业 class:

template <class T, typename... Args>
struct JobMemberFunc : IJob
{
    JobMemberFunc(T* aParent, void (T::* f)(Args...), Args... Args)
    {
        parentObj = aParent;
        func_ptr = f;
        saved_args = ::std::make_tuple (::std::move(Args)...);
    }

    virtual bool invoke() override
    {
        if (!parentObj) { return false; }

        (parentObj->*func_ptr)(::std::move(saved_args));
        return true;
    }

    /** the object to invoke the function pointer on */
    T* parentObj;

    /** The function pointer to call when we invoke this function */
    void (T::* func_ptr)(Args...);

    ::std::tuple<Args...> saved_args;
};


struct CpuJob
{
    IJob* jobPtr = nullptr;
};

然后是 AddJob 方法，实际发生了内部编译器错误。

template <typename T, typename... Args>
void AddJob(T* aParent, void(T::* func_ptr)(Args...), Args... args)
{//This curly bracket is where the internal compiler error happens
    CpuJob aJob = {};

    JobMemberFunc<T, Args...>* jobPtr = new JobMemberFunc<T, Args...>(aParent, func_ptr, 
    std::forward<Args>(args)...);

    aJob.jobPtr = jobPtr;

    locklessReadyQueue.enqueue(aJob);
}

很高兴得知这是 bad/wrong 尝试这样做的方式。我考虑过取消它并拥有一个标准化的参数列表或做一些多态性的事情，但我真的很想完成这项工作，这样我就可以直接要求工作系统做任何我喜欢的事情。

谢谢！

Answer 1

std::function<void()>（与 lambda 结合使用）已经完成了您尝试使用 JobMemberFunc.

所做的事情

void AddJob(std::function<void()>&& job)
{
    locklessReadyQueue.enqueue(std::move(job));
}

有了这个，您可以将任何函数调用作为作业提交。

例如，调用 some_obj.some_method(some_arg) 变为：

  AddJob([&] { some_obj.some_method(some_arg); });

不再有丑陋的指向成员的指针...

您可以在此处找到更完整的线程池示例：Thread pooling in C++11

在 C++ 中扩展 Job/Worker 多线程系统

Expanding on a Job/Worker multi-threading system in C++

c++

multithreading

templates

variadic