多線(xiàn)程編程之：Linux線(xiàn)程編程

　　9.2 Linux線(xiàn)程編程

　　9.2.1 線(xiàn)程基本編程

　　這里要講的線(xiàn)程相關(guān)操作都是用戶(hù)空間中的線(xiàn)程的操作。在Linux中，一般pthread線(xiàn)程庫是一套通用的線(xiàn)程庫，是由POSIX提出的，因此具有很好的可移植性。

　　(1)函數說(shuō)明。

　　創(chuàng )建線(xiàn)程實(shí)際上就是確定調用該線(xiàn)程函數的入口點(diǎn)，這里通常使用的函數是pthread_create()。在線(xiàn)程創(chuàng )建以后，就開(kāi)始運行相關(guān)的線(xiàn)程函數，在該函數運行完之后，該線(xiàn)程也就退出了，這也是線(xiàn)程退出一種方法。另一種退出線(xiàn)程的方法是使用函數pthread_exit()，這是線(xiàn)程的主動(dòng)行為。這里要注意的是，在使用線(xiàn)程函數時(shí)，不能隨意使用exit()退出函數進(jìn)行出錯處理，由于exit()的作用是使調用進(jìn)程終止，往往一個(gè)進(jìn)程包含多個(gè)線(xiàn)程，因此，在使用exit()之后，該進(jìn)程中的所有線(xiàn)程都終止了。因此，在線(xiàn)程中就可以使用pthread_exit()來(lái)代替進(jìn)程中的exit()。

　　由于一個(gè)進(jìn)程中的多個(gè)線(xiàn)程是共享數據段的，因此通常在線(xiàn)程退出之后，退出線(xiàn)程所占用的資源并不會(huì )隨著(zhù)線(xiàn)程的終止而得到釋放。正如進(jìn)程之間可以用wait()系統調用來(lái)同步終止并釋放資源一樣，線(xiàn)程之間也有類(lèi)似機制，那就是pthread_join()函數。pthread_join()可以用于將當前線(xiàn)程掛起來(lái)等待線(xiàn)程的結束。這個(gè)函數是一個(gè)線(xiàn)程阻塞的函數，調用它的函數將一直等待到被等待的線(xiàn)程結束為止，當函數返回時(shí)，被等待線(xiàn)程的資源就被收回。

　　前面已提到線(xiàn)程調用pthread_exit()函數主動(dòng)終止自身線(xiàn)程。但是在很多線(xiàn)程應用中，經(jīng)常會(huì )遇到在別的線(xiàn)程中要終止另一個(gè)線(xiàn)程的執行的問(wèn)題。此時(shí)調用pthread_cancel()函數實(shí)現這種功能，但在被取消的線(xiàn)程的內部需要調用pthread_setcancel()函數和pthread_setcanceltype()函數設置自己的取消狀態(tài)，例如被取消的線(xiàn)程接收到另一個(gè)線(xiàn)程的取消請求之后，是接受還是忽略這個(gè)請求;如果接受，是立刻進(jìn)行終止操作還是等待某個(gè)函數的調用等。

　　(2)函數格式。

　　表9.1列出了pthread_create()函數的語(yǔ)法要點(diǎn)。

　　表9.2列出了pthread_exit()函數的語(yǔ)法要點(diǎn)。

　　表9.3列出了pthread_join()函數的語(yǔ)法要點(diǎn)。

　　表9.4列出了pthread_cancel()函數的語(yǔ)法要點(diǎn)。

　　(3)函數使用。

　　以下實(shí)例中創(chuàng )建了3個(gè)線(xiàn)程，為了更好地描述線(xiàn)程之間的并行執行，讓3個(gè)線(xiàn)程重用同一個(gè)執行函數。每個(gè)線(xiàn)程都有5次循環(huán)(可以看成5個(gè)小任務(wù))，每次循環(huán)之間會(huì )隨機等待1～10s的時(shí)間，意義在于模擬每個(gè)任務(wù)的到達時(shí)間是隨機的，并沒(méi)有任何特定規律。

　　/* thread.c */

　　#include

　　#include

　　#include

　　#define THREAD_NUMBER 3 /*線(xiàn)程數*/

　　#define REPEAT_NUMBER 5 /*每個(gè)線(xiàn)程中的小任務(wù)數*/

　　#define DELAY_TIME_LEVELS 10.0 /*小任務(wù)之間的最大時(shí)間間隔*/

　　void *thrd_func(void *arg)

　　{ /* 線(xiàn)程函數例程 */

　　int thrd_num = (int)arg;

　　int delay_time = 0;

　　int count = 0;

　　printf("Thread %d is startingn", 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 = %dn",

　　thrd_num, count, delay_time);

　　}

　　printf("Thread %d finishedn", 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++)

　　{

　　/* 創(chuàng )建多線(xiàn)程 */

　　res = pthread_create(&thread[no], NULL, thrd_func, (void*)no);

　　if (res != 0)

　　{

　　printf("Create thread %d failedn", no);

　　exit(res);

　　}

　　}

　　printf("Create treads successn Waiting for threads to finish...n");

　　for (no = 0; no < THREAD_NUMBER; no++)

　　{

　　/* 等待線(xiàn)程結束 */

　　res = pthread_join(thread[no], &thrd_ret);

　　if (!res)

　　{

　　printf("Thread %d joinedn", no);

　　}

　　else

　　{

　　printf("Thread %d join failedn", no);

　　}

　　}

　　return 0;

　　}

　　以下是程序運行結果?？梢钥闯雒總€(gè)線(xiàn)程的運行和結束是獨立與并行的。

　　$ ./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