产生多个std :: thread并重用它

卡尔88

我是一个菜鸟,需要一些帮助/建议。首先,可以通过以下代码检查我的理解是否正确:

std::vector<std::unique_ptr<Object>> totalObjects(512);
std::vector<Object*> objectsToUpdate(32);
std::vector<std::thread> threadsPool(32);

int nrObjectsToUpdate; //Varies between 1 and 32 for each update.

findObjectsToUpdate(totalObjects, objectsToUpdate, nrObjectsToUpdate);

for(int i = 0; i < nrObjectsToUpdate; i++)
    threadsPool[i] = std::thread(objectsToUpdate[i]->updateTask1());

//All tasks in this step must be completed before 
//we can move on to the next, i.e. updateTask2();.
for(int i = 0; i < nrObjectsToUpdate; i++)
    threadsPool[i].join();

for(int i = 0; i < nrObjectsToUpdate; i++)
    threadsPool[i] = std::thread(objectsToUpdate[i]->updateTask2());

for(int i = 0; i < nrObjectsToUpdate; i++)
    threadsPool[i].join();

我是否应该为每个updateTask1()和updateTask2()生成一个线程?对于每次更新,是否都需要重新创建std :: thread()?还是可以简单地通过某些成员函数再次重用它?如果我为updateTask1()创建线程,是否可以将所有线程对象重用于updateTask2()?即用某些std :: thread成员函数切换函数指针?

假设我们创建了100个线程,并且有一个四核CPU(4个内核),在所有线程完成之前,所有CPU内核都会忙吗?我至少知道4个核心意味着4个线程。

感谢所有可以提供的帮助和解释。

罗布·克鲁卡斯

使用的最佳线程数取决于应用程序和硬件,因此,应产生的线程数取决于您的应用程序。

例如,某些应用程序可能在每个内核有多个线程的情况下运行良好,因为这些线程不会互相干扰(例如,内核1上的线程X和线程Y不需要争用计算资源,因此通过多个线程可以获得优势)每个核心的线程数)。但是,其他应用程序在每个内核上使用多个线程的性能可能会更差,因为仅使用一个线程可能会占用内核的大部分资源,因此,当在每个内核上使用其他线程时,这些线程会相互干扰。您应该进行一些测试,以找出最适合您的应用程序的线程配置。多线程通常并不简单,其性能结果可能令人惊讶。

您可以使用许多方法来帮助确定线程数和线程调度(不过您仍然应该进行性能测试)。

您可以unsigned num_cpus = std::thread::hardware_concurrency();用来获取可用CPU的数量。尽管您可能知道正在使用的CPU的内核数,但也许您想在另一台您不知道其内核数的机器上运行它。

此外,还有处理器亲和力,它本质上是将某些线程固定到特定的CPU。默认情况下,允许操作系统将任何产生的线程调度到任何CPU。有时,这会导致每个CPU有多个线程,并且某些CPU未被用于多线程组件的某些部分。您可以通过以下方式显式设置特定线程以使用特定CPU pthread_setaffinity_np:(对要固定到核心的每个线程执行此操作):

cpu_set_t cpu_set;
CPU_ZERO(&cpu_set);
CPU_SET(i, &cpu_set);
int rc = pthread_setaffinity_np(threadsPool[i].native_handle(),
                                sizeof(cpu_set_t), &cpu_set);

// Check for error
if (rc != 0) 
    std::cerr << "pthread_setaffinity_np error: " << rc << "\n";

如果我为updateTask1()创建线程,是否可以将所有线程对象重用于updateTask2()?即用某些std :: thread成员函数切换函数指针?

是的,您可以这样做。在程序中关于使用线程的逻辑updateTask1()updateTask2()是正确的,但是,语法已分配线程时所犯的错误。

threadsPool[i] = std::thread(objectsToUpdate[i]->updateTask1());

是不正确的。您想使用成员函数作为为每个线程生成的函数,因此您需要传递对该函数的引用以及要绑定的对象,然后传递任何其他参数(例如,updateTask1还会添加该函数的对象ID i)。线程的分配应如下所示:

threadsPool[i] = std::thread(&Object::updateTask1,  // Reference to function
                             objectsToUpdate[i]  ,  // Object to bind to
                             i );                   // Additional argument -- thread number

然后,您可以对使用相同的语法updateTask2这是一个现场演示,包括处理器关联。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

跨多个模型导出并重用我的猫鼬连接

来自分类Dev

如何在jquery中创建函数并重用它们

来自分类Dev

UIStoryboard定义一个collectionViewCell并重用它

来自分类Dev

生成唯一变量并重用它们

来自分类Dev

Java:如何提供唯一的ID并重用它们?

来自分类Dev

如何清理使用堆栈(haskell)创建的目录并重用它?

来自分类Dev

python multiprocessing,为每个进程创建实例并重用它

来自分类Dev

链接多个可观察对象并重用链中已执行的结果

来自分类Dev

我可以以编程方式获取xml布局并重用它吗?

来自分类Dev

如何定义 makefile 条件并在多个构建规则中重用它?

来自分类Dev

使用std :: thread组合来自多个线程的数组

来自分类Dev

将布尔值分配给局部变量并重用它还是使用if进行重复比较是否更好?

来自分类Dev

在 Keras/TF 中,有没有办法预训练模型并重用它来测试其他可能的层?

来自分类Dev

ExecutorService 不能重用它的线程

来自分类Dev

产生多个子进程

来自分类Dev

重用多个模块的指令

来自分类Dev

在scikit中保存并重用TfidfVectorizer学习

来自分类Dev

通过合并重用密码中的关系

来自分类Dev

Scanf跳过变量并重用旧变量

来自分类Dev

合并并重用PHP Array

来自分类Dev

如何生成使用std :: thread C ++调用同一功能的多个线程

来自分类Dev

如何使用std :: thread C ++生成多个调用同一函数的线程

来自分类Dev

WebGL多个光源产生黑边

来自分类Dev

产生多个圆圈并使它们移动

来自分类Dev

使用scrapy产生多个项目

来自分类Dev

使用scrapy产生多个项目

来自分类Dev

tmux如何产生多个会话?

来自分类Dev

删除和图像并重新写回会产生错误

来自分类Dev

在多个设置中重用代码

Related 相关文章

热门标签

归档