pthread_create()是Linux中建立執行緒的一種方式。

#include<pthread.h>

int pthread_create(pthread_t *tidp,const pthread_attr_t *attr,(void*)(*start_rtn)(void*) ,void *arg);

//第一個引數為指向執行緒識別符號的指標。
//第二個引數用來設定執行緒屬性。
//第三個引數是執行緒執行函式的起始地址。
//第四個引數是執行函式的引數。
//pthread_create() 在呼叫成功完成之後返回零。其他任何返回值都表示出現了錯誤。

最近在使用時需要用到呢多執行緒，所以就用for語句迴圈建立了多個執行緒，但是出現了一些問題，特此記錄下。

我一開始是這樣是這樣寫的：

pthread_t *pt=(pthread_t*)malloc(num_threads*sizeof(pthread_t));
for(int a=0;a<num_threads;a++)
    pthread_create(&pt[a],NULL,function,&a);
for(int a=0;a<num_threads;a++)
    pthread_join(pt[a],NULL);

我建立執行緒時是需要把a傳入函式function中的，但是，這樣會出現混亂，比如，我們需要往第0個執行緒傳入引數0，實際上執行結果顯示傳入第0個執行緒的引數不是0。

在網上查了一下，大概問題就是，CPU執行速度很快，而pthread_create()建立執行緒要有一定的時間，在pthread_create()建立執行緒再去按照之前引數a的地址去取a時，迴圈中a的值已經發生了變化，這就造成傳入函式function的引數值不對。

既然這樣，我就讓主執行緒迴圈時等一下pthread_create()不就ok了，於是程式碼變成下面這樣：

pthread_t *pt=(pthread_t*)malloc(num_threads*sizeof(pthread_t));
for(int a=0;a<num_threads;a++)
{
    pthread_create(&pt[a],NULL,function,&a);
    sleep(1);  //#include<unistd.h>
}
for(int a=0;a<num_threads;a++)
    pthread_join(pt[a],NULL);
 

迴圈時主執行緒掛起1秒鐘，pthread_create()就建立執行緒完畢了，但這樣帶來的問題就是：我們使用多執行緒的初衷就是並行運算、提升效率，但每建立一個執行緒就能停1秒，如果我們建立執行緒的次數比較多，那將大大影響程式的整體執行效率。而我試了一下，如果將sleep(1)改成usleep(1000)，即睡眠1000微秒（1毫秒），仍可能出現錯誤。

在網上查了下，通過實踐，發現以下兩種方法可以解決：

1、實現開闢一塊空間儲存建立多執行緒時所需要傳入的引數，這樣每個執行緒的引數的地址就不會亂套。

2、在迴圈建立執行緒時，我們不直接把迴圈的控制變數（如上例中的a）直接傳入多執行緒的函式中，我們另外申請一塊空間，儲存在這塊空間上，到時再從這塊空間取值就行了。

兩種方法的解決方法如下：

//第一種方法

pthread_t *pt=(pthread_t*)malloc(num_threads*sizeof(pthread_t));
int order[num_threads];
for(int a=0;a<num_threads;a++)
    order[a]=a;
for(int a=0;a<num_threads;a++)
    pthread_create(&pt[a],NULL,function,&order[a]);
for(int a=0;a<num_threads;a++)
    pthread_join(pt[a],NULL);


//第二種方法
pthread_t *pt=(pthread_t*)malloc(num_threads*sizeof(pthread_t));
for(int a=0;a<num_threads;a++)
{
    int* temp=(int*)malloc(sizeof(int));
    *temp=a;
    pthread_create(&pt[a],NULL,function,(void*)temp);
}
for(int a=0;a<num_threads;a++)
    pthread_join(pt[a],NULL);

兩種效果方法差不多，但是第二種方法使用malloc申請了動態記憶體，而且還沒有釋放，所以不是太好。

我疑惑的是，在一些地方，如下的程式碼竟然能跑，而且完全沒問題。。。？（感覺和我寫的一模一樣啊= - =）我也沒搞懂沒什麼，真的很奇怪。歡迎懂得大佬們留言我。

pthread_t *pt=(pthread_t *)malloc(num_threads*sizeof(pthread_t));
for (int a=0;a <num_threads;a++)
    pthread_create(&pt[a],NULL,function, &a);
for (int a= 0;a<num_threads;a++)
    pthread_join(pt[a],NULL);

參考：