9.2 Linux線程編程
　　9.2.1 線程基本編程
　　這里要講的線程相關操作都是用戶空間中的線程的操作。在Linux中，一般pthread線程庫是一套通用的線程庫，是由POSIX提出的，因此具有很好的可移植性。
　　（1）函數說明。
　　創建線程實際上就是確定調用該線程函數的入口點，這里通常使用的函數是pthread_create（）。在線程創建以后，就開始運行相關的線程函數，在該函數運行完之后，該線程也就退出了，這也是線程退出一種方法。另一種退出線程的方法是使用函數pthread_exit（），這是線程的主動行為。這里要注意的是，在使用線程函數時，不能隨意使用exit（）退出函數進行出錯處理，由于exit（）的作用是使調用進程終止，往往一個進程包含多個線程，因此，在使用exit（）之后，該進程中的所有線程都終止了。因此，在線程中就可以使用pthread_exit（）來代替進程中的exit（）。
　　由于一個進程中的多個線程是共享數據段的，因此通常在線程退出之后，退出線程所占用的資源并不會隨著線程的終止而得到釋放。正如進程之間可以用wait（）系統調用來同步終止并釋放資源一樣，線程之間也有類似機制，那就是pthread_join（）函數。pthread_join（）可以用于將當前線程掛起來等待線程的結束。這個函數是一個線程阻塞的函數，調用它的函數將一直等待到被等待的線程結束為止，當函數返回時，被等待線程的資源就被收回。
　　前面已提到線程調用pthread_exit（）函數主動終止自身線程。但是在很多線程應用中，經常會遇到在別的線程中要終止另一個線程的執行的問題。此時調用pthread_cancel（）函數實現這種功能，但在被取消的線程的內部需要調用pthread_setcancel（）函數和pthread_setcanceltype（）函數設置自己的取消狀態，例如被取消的線程接收到另一個線程的取消請求之后，是接受還是忽略這個請求；如果接受，是立刻進行終止操作還是等待某個函數的調用等。
　　（2）函數格式。
　　表9.1列出了pthread_create（）函數的語法要點。
　　表9.1 pthread_create（）函數語法要點
　　所需頭文件#include 《pthread.h》
　　函數原型int pthread_create （（pthread_t *thread， pthread_attr_t *attr，
　　void *（*start_routine）（void *）， void *arg））
　　函數傳入值thread：線程標識符
　　attr：線程屬性設置（其具體設置參見9.2.3小節），通常取為NULL
　　start_routine：線程函數的起始地址，是一個以指向void的指針作為參數和返回值的函數指針
　　arg：傳遞給start_routine的參數
　　函數返回值成功：0
　　出錯：返回錯誤碼
　　表9.2列出了pthread_exit（）函數的語法要點。
　　表9.2 pthread_exit（）函數語法要點
　　所需頭文件#include 《pthread.h》
　　函數原型void pthread_exit（void *retval）
　　函數傳入值retval：線程結束時的返回值，可由其他函數如pthread_join（）來獲取
　　表9.3列出了pthread_join（）函數的語法要點。
　　表9.3 pthread_join（）函數語法要點
　　所需頭文件#include 《pthread.h》
　　函數原型int pthread_join （（pthread_t th， void **thread_return））
　　函數傳入值th：等待線程的標識符
　　thread_return：用戶定義的指針，用來存儲被等待線程結束時的返回值（不為NULL時）
　　函數返回值成功：0
　　出錯：返回錯誤碼
　　表9.4列出了pthread_cancel（）函數的語法要點。
　　表9.4 pthread_cancel（）函數語法要點
　　所需頭文件#include 《pthread.h》
　　函數原型int pthread_cancel（（pthread_t th）
　　函數傳入值th：要取消的線程的標識符
　　函數返回值成功：0
　　出錯：返回錯誤碼
　　（3）函數使用。
　　以下實例中創建了3個線程，為了更好地描述線程之間的并行執行，讓3個線程重用同一個執行函數。每個線程都有5次循環（可以看成5個小任務），每次循環之間會隨機等待1～10s的時間，意義在于模擬每個任務的到達時間是隨機的，并沒有任何特定規律。
　　/* thread.c */
　　#include 《stdio.h》
　　#include 《stdlib.h》
　　#include 《pthread.h》
　　#define THREAD_NUMBER 3 /*線程數*/
　　#define REPEAT_NUMBER 5 /*每個線程中的小任務數*/
　　#define DELAY_TIME_LEVELS 10.0 /*小任務之間的最大時間間隔*/
　　void *thrd_func（void *arg）
　　{ /* 線程函數例程 */
　　int thrd_num = （int）arg;
　　int delay_time = 0;
　　int count = 0;
　　printf（“Thread %d is starting\n”， thrd_num）;
　　for （count = 0; count 《 REPEAT_NUMBER; count++）
　　{
　　delay_time = （int）（rand（） * DELAY_TIME_LEVELS/（RAND_MAX）） + 1;
　　sleep（delay_time）;
　　printf（“\tThread %d： job %d delay = %d\n”，
　　thrd_num， count， delay_time）;
　　}
　　printf（“Thread %d finished\n”， thrd_num）;
　　pthread_exit（NULL）;
　　}
　　int main（void）
　　{
　　pthread_t thread［THREAD_NUMBER］;
　　int no = 0， res;
　　void * thrd_ret;
　　srand（time（NULL））;
　　for （no = 0; no 《 THREAD_NUMBER; no++）
　　{
　　/* 創建多線程 */
　　res = pthread_create（&thread［no］， NULL， thrd_func， （void*）no）;
　　if （res ！= 0）
　　{
　　printf（“Create thread %d failed\n”， no）;
　　exit（res）;
　　}
　　}
　　printf（“Create treads success\n Waiting for threads to finish.。.\n”）;
　　for （no = 0; no 《 THREAD_NUMBER; no++）
　　{
　　/* 等待線程結束 */
　　res = pthread_join（thread［no］， &thrd_ret）;
　　if （！res）
　　{
　　printf（“Thread %d joined\n”， no）;
　　}
　　else
　　{
　　printf（“Thread %d join failed\n”， no）;
　　}
　　}
　　return 0;
　　}
　　以下是程序運行結果。可以看出每個線程的運行和結束是獨立與并行的。
　　$ 。/thread
　　Create treads success
　　Waiting for threads to finish.。.
　　Thread 0 is starting
　　Thread 1 is starting
　　Thread 2 is starting
　　Thread 1： job 0 delay = 6
　　Thread 2： job 0 delay = 6
　　Thread 0： job 0 delay = 9
　　Thread 1： job 1 delay = 6
　　Thread 2： job 1 delay = 8
　　Thread 0： job 1 delay = 8
　　Thread 2： job 2 delay = 3
　　Thread 0： job 2 delay = 3
　　Thread 2： job 3 delay = 3
　　Thread 2： job 4 delay = 1
　　Thread 2 finished
　　Thread 1： job 2 delay = 10
　　Thread 1： job 3 delay = 4
　　Thread 1： job 4 delay = 1
　　Thread 1 finished
　　Thread 0： job 3 delay = 9
　　Thread 0： job 4 delay = 2
　　Thread 0 finished
　　Thread 0 joined
　　Thread 1 joined
　　Thread 2 joined