C 11动态线程池

Question

最近，我一直在尝试寻找一个用于线程并发任务的库。理想情况下，一个简单的接口，调用线程上的函数。任何时候都有n个线程，有些线程完成得比其他线程快，并且在不同的时间到达。

首先我在试Rx，这在c语言中很好。我也研究了区块和TBB，但它们都依赖于平台。对于我的原型，我需要保持平台独立性，因为我们还不知道它将在什么平台上运行，并且在做出决定时可以更改。

C 11有很多关于线程和并发的东西，我发现了很多关于线程池的例子。

https://github.com/bilash/threadpool

类似的项目使用相同的lambda表达式与std::线程和std::互斥锁。

这看起来非常适合我的需要。这里有一些问题。池由定义数量的线程启动，任务排队，直到一个线程空闲。

如何添加新线程？删除过期的线程？（.Join（）？？）

显然，对于已知数量的线程来说，这要容易得多，因为它们可以在ctor中初始化，然后在dtor中加入join（）。

有C并发经验的人有什么建议吗？

Answer 1

这应该很容易使用：https://pocoproject.org/docs/Poco.ThreadPool.html

线程池总是让多个线程运行，随时准备接受工作。创建和启动线程会给应用程序带来巨大的运行时开销。线程池通过减少必须创建（并再次销毁）的线程数量，有助于提高应用程序的性能。线程池中的线程一旦再次可用，就会被重用。线程池始终保持最少数量的线程运行。如果对线程的需求增加，就会创建额外的线程。一旦对线程的需求再次下降，不再使用的线程将停止并从池中移除。

ThreadPool(
    int minCapacity = 2,
    int maxCapacity = 16,
    int idleTime = 60,
    int stackSize = 0
);

这是一个非常好的库，易于使用，不像Boost：（

https://github.com/pocoproject/poco

Answer 2

>

从系统可以支持的最大线程数开始：

int Num_Threads =  thread::hardware_concurrency();

为了实现高效的线程池，一旦根据Num_线程创建了线程，最好不要创建新的线程，也不要破坏旧的线程（通过加入）。这将导致性能下降，甚至可能使应用程序运行速度比串行版本慢。

每个C 11线程都应该在其函数中以无限循环运行，不断等待新任务抓取并运行。

下面是如何将此类函数附加到线程池：

int Num_Threads = thread::hardware_concurrency();
vector<thread> Pool;
for(int ii = 0; ii < Num_Threads; ii++)
{  Pool.push_back(thread(Infinite_loop_function));}

Infinite_loop_function

这是一个等待任务队列的“当（真）”循环

void The_Pool:: Infinite_loop_function()
{
    while(true)
    {
        {
            unique_lock<mutex> lock(Queue_Mutex);

            condition.wait(lock, []{return !Queue.empty()});
            Job = Queue.front();
            Queue.pop();
        }
        Job(); // function<void()> type
    }
};

创建一个函数，将作业添加到队列中

void The_Pool:: Add_Job(function<void()> New_Job)
{
    {
        unique_lock<mutex> lock(Queue_Mutex);
        Queue.push(New_Job);
    }
    condition.notify_one();
}

将任意函数绑定到您的队列

Pool_Obj.Add_Job(std::bind(&Some_Class::Some_Method, &Some_object));

一旦你整合了这些元素，你就拥有了自己的动态线程池。这些线程总是在运行，等待作业完成。