2013-04-25 103 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