2013-04-25 68 views
0

我正在尝试做一些并行编程。我已经以下的导向和我有这样的代码: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秒的速度完成。那为什么我需要多处理。

+1

你能提供一个链接到教程或导向哪里,这是从?制作多线程并不一定意味着任何事情都会更快地执行。创建和管理线程的开销有时甚至会减慢执行速度。 – Excelcius 2013-04-25 17:49:38

+0

这里是公会:http://www.dreamincode.net/forums/topic/52380-multi-threading-on-multi-processors/ 添加1所涉及的varible就是一个例子。我有一个非常复杂的程序,正在以8-9秒的速度完成。那为什么我需要多处理。 – user2320928 2013-04-25 18:03:49

回答

3

如果你没有运行您的多处理器/多核心系统代码,那么你将不会看到任何性能增益。

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

+0

+1。在单核机器上,线程只有在单个线程等待某些事情(通常是I/O)时才真正有用。对于多核,工作的粒度成为关键;太小,你会花时间只是切换上下文。 – cHao 2013-04-26 15:48:10