c++并行编程错误

c++ parallel programming bug

本文关键字:错误 编程 并行 c++      更新时间:2023-10-16

我正在尝试做一些并行编程。我一直在遵循指南,我有这个代码:

void main() 
{
    CPUs = GetNumCPUs();
    HANDLE *threads = new HANDLE[CPUs];
    queues = new queue<functionPointer>[CPUs];
    DWORD_PTR threadID = 0;
    DWORD_PTR threadCore = 1 << 0;
    threads[0] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)loop, (LPVOID)&queues, NULL, &threadID);
    SetThreadAffinityMask(threads[0], threadCore);
    for (DWORD_PTR i = 1; i < CPUs; i++)
    {
        threadID = i;
        threadCore = 1 << i;
        threads[i] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)Coroutine, (LPVOID)&queues[i], NULL, &threadID);
        SetThreadAffinityMask(threads[i], threadCore);
        wprintf(L"Creating Thread %d (0x%08x) Assigning to CPU 0x%08xrn", i, (LONG_PTR)threads[i], threadCore);
    }
    while(true) Sleep(1000);
}

线程函数只是给变量加1。我已经看到,这段代码并不比没有线程的代码快。我想我做错了什么,它不是多核的。这是什么?

这是公会:http://www.dreamincode.net/forums/topic/52380-multi-threading-on-multi-processors/a变量加1就是一个例子。我有一个非常复杂的程序,需要8-9秒才能完成。这就是为什么我需要多处理

如果您的代码不是在多处理器/多核系统上运行,那么您将看不到任何性能增益。

如果你是,但你的线程只是做简单的处理(添加1到一个变量?),它可能会花费更多的处理器周期来产生/关闭线程比它做线程的工作。在这种情况下,您最好在单个线程中完成所有工作。