我是一个菜鸟,需要一些帮助/建议。首先,可以通过以下代码检查我的理解是否正确:
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] 删除。
我来说两句