jrphy / multiple_thread Goto Github PK

程式 Program, 進程 Process 與線程(執行緒) Thread 的差異： Program：一段程式碼寫好但尚未被執行
Process：程式被執行後會佔有資源，並且由 OS 去分配資源。每個進程之間是互相獨立的，可以藉由訊息傳遞(Message passing)或記憶體共享(Share Memory)來交換資料，達到多進程的效果。一個程式會佔據一個 CPU 的核心，多核心的 CPU 就可以同時執行多個程式。而每個程式裡面還有一個或多個線程，可以看成是線程的容器。每個程式在 OS 中會被賦予一個 pid，在 windows 中可以用工作管理員看，linux 則是用 top 查看。
Thread：Process 分配到資源後，實際執行者是線程，是 OS 分配 CPU-time 的單位，也就是執行的最小單位。每個程式內的執行緒可以直接共享全域變數。

並行與平行的差異在於是由幾個 CPU 核心在處理，若有多個任務在多個 CPU 核心處理則稱為平行，而多個任務在一個 CPU 核心處理則稱為併行。

在 C/C++ 中，平行的任務會有多個 main() 函數同時被執行，例如在算矩陣的 det 時，我可以整個矩陣一起算，也可以把矩陣分成多個小方陣，算出個別的 det 在相乘。
det(A) = det(A₁)det(A₂)...det(A_n)
這時就可以寫一個計算 det 的 main 函數，然後分別把 A₁、A₂ ... A_n 的資料丟進作計算，最後算出來在做相乘。而並行則是把 A 中的所有元素傳進一個 main() 裡面，再去開 thread 去分別做計算，算完後直接在 main() 裡面做相乘，結束後算出來的就是 det(A)。例如有個程式 det_cal 如下

#include <iostream>
#include <fstream>
#include <cstdlib>    //使用exit必須include
using namespace std;
int main(int argc, char *argv[]) {
    ifstream in;
    in.open(argv[1]);
    // 計算行列式值
    return 0;
}

另外有個陣列元素存於 A.txt 中，若要分成四個矩陣去做運算，那需要自行將檔案拆成四分，然後個別執行，最後再將計算的值乘起來即為 det(A)。如果為 linux，則需要開四個 terminal 然後個別去跑

./det_cal A1.txt
./det_cal A2.txt
./det_cal A3.txt
./det_cal A4.txt

與平行不同地方在於，並行的程式只會有一個 main()，並且只會執行一個，並不像上面要執行四個。而並行的程式設計需要在裡面另外去開 thread，C++ 需要用 C++11 以上的標準，C 則是要 C11 以上的標準，也可使用 linux 本身的 pthread 來做開發。

#include <iostream>
#include <thread>
using namespace std;
void determinant()
{
    ...
}
int main(int argc, char *argv[]) {
{
    ifstream in;
    in.open(argv[1]);
    // 計算行列式值
    int A1[n][n], A2[n][n], A3[n][n], A4[n][n];
    // 建立執行緒
    thread first_thread(determinant, A1);
    thread second_thread(determinant, A2); 
    thread third_thread(determinant, A3);
    thread fourth_thread(determinant, A4);
    // 將主執行緒暫停，等待指定的執行緒結束
    first_thread.join();
    second_thread.join();
    third_thread.join();
    fourth_thread.join();
    return 0;
}

最後執行 ./det_cal A.txt 即可。跟平行程式不同的地方在於，並行程式是在程式內部做資料切割，且從同到尾只會占用一個 CPU 核心。