我正在尝试做一些并行编程。我已经以下的导向和我有这样的代码:C++并行编程错误
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变量是一个例子。我有一个非常复杂的程序,正在以8-9秒的速度完成。那为什么我需要多处理。
你能提供一个链接到教程或导向哪里,这是从?制作多线程并不一定意味着任何事情都会更快地执行。创建和管理线程的开销有时甚至会减慢执行速度。 – Excelcius 2013-04-25 17:49:38
这里是公会:http://www.dreamincode.net/forums/topic/52380-multi-threading-on-multi-processors/ 添加1所涉及的varible就是一个例子。我有一个非常复杂的程序,正在以8-9秒的速度完成。那为什么我需要多处理。 – user2320928 2013-04-25 18:03:49