我正在尝试做一些并行编程。我一直在遵循指南,并且有以下代码:
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%08x\r\n", i, (LONG_PTR)threads[i], threadCore);
}
while(true) Sleep(1000);
}
线程函数只是将 1 添加到变量中。我已经看到这段代码并不比没有线程的代码快。我认为我做错了什么,它不是多核的。它是什么?
这是公会:http ://www.dreamincode.net/forums/topic/52380-multi-threading-on-multi-processors/ 添加 1 a 变量就是一个例子。我有一个非常复杂的程序,需要 8-9 秒才能完成。这就是为什么我需要多处理。