當(dāng)前位置：首頁 > 运维知识 > linux >内容正文

linux

linux中多线程解析

發(fā)布時(shí)間：2024/1/17 linux 21 豆豆

生活随笔收集整理的這篇文章主要介紹了 linux中多线程解析小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

Linux系統(tǒng)下的多線程遵循POSIX線程接口，稱為 pthread。編寫Linux下的多線程程序，需要使用頭文件pthread.h，連接時(shí)需要使用庫libpthread.a。順便說一下，Linux 下pthread的實(shí)現(xiàn)是通過系統(tǒng)調(diào)用clone（）來實(shí)現(xiàn)的。clone（）是 Linux所特有的系統(tǒng)調(diào)用，它的使用方式類似fork，關(guān)于clone（）的詳細(xì)情況，有興趣的讀者可以去查看有關(guān)文檔說明。下面我們展示一個(gè)最簡單的多線程程序 pthread_create.c。

一個(gè)重要的線程創(chuàng)建函數(shù)原型：
#include <pthread.h>
int pthread_create(pthread_t *restrict tidp,const pthread_attr_t *restrict attr, void *(*start_rtn)(void),void *restrict arg);

??? 返回值：若是成功建立線程返回0,否則返回錯(cuò)誤的編號
??? 形式參數(shù)：
??????????????? pthread_t *restrict tidp 要?jiǎng)?chuàng)建的線程的線程id指針
??????????????? const pthread_attr_t *restrict attr 創(chuàng)建線程時(shí)的線程屬性
??????????????? void* (start_rtn)(void) 返回值是void類型的指針函數(shù)
??????????????? void *restrict arg?? start_rtn的行參
?????????????? ?
例程1：????????????????????????????? ?
??? 功能：創(chuàng)建一個(gè)簡單的線程
??? 程序名稱：pthread_create.c??????
/********************************************************************************************
**??? Name:pthread_create.c
**??? Used to study the multithread programming in Linux OS
**??? Author:zeickey
**??? Date:2006/9/16????? ?
**??? Copyright (c) 2006,All Rights Reserved!
*********************************************************************************************/

#include <stdio.h>
#include <pthread.h>

void *myThread1(void)
{
??? int i;
??? for (i=0; i<100; i++)
??? {
??????? printf("This is the 1st pthread,created by zieckey./n");
??????? sleep(1);//Let this thread to sleep 1 second,and then continue to run
??? }
}

void *myThread2(void)
{
??? int i;
??? for (i=0; i<100; i++)
??? {
??????? printf("This is the 2st pthread,created by zieckey./n");
??????? sleep(1);
??? }
}

int main()
{
??? int i=0, ret=0;
??? pthread_t id1,id2;
? ?
??? ret = pthread_create(&id2, NULL, (void*)myThread1, NULL);
??? if (ret)
??? {
??????? printf("Create pthread error!/n");
??????? return 1;
??? }
? ?
??? ret = pthread_create(&id2, NULL, (void*)myThread2, NULL);
??? if (ret)
??? {
??????? printf("Create pthread error!/n");
??????? return 1;
??? }
? ?
??? pthread_join(id1, NULL);
??? pthread_join(id2, NULL);
? ?
??? return 0;
}

我們編譯此程序：
# gcc pthread_create.c -lpthread

因?yàn)閜thread的庫不是linux系統(tǒng)的庫，所以在進(jìn)行編譯的時(shí)候要加上-lpthread，否則編譯不過，會(huì)出現(xiàn)下面錯(cuò)誤
thread_test.c: 在函數(shù) ‘create’ 中：
thread_test.c:7: 警告：在有返回值的函數(shù)中，程序流程到達(dá)函數(shù)尾
/tmp/ccOBJmuD.o: In function `main':thread_test.c:(.text+0x4f)：對‘pthread_create’未定義的引用
collect2: ld 返回 1

運(yùn)行，我們得到如下結(jié)果：
# ./a.out
This is the 1st pthread,created by zieckey.
This is the 2st pthread,created by zieckey.
This is the 1st pthread,created by zieckey.
This is the 2st pthread,created by zieckey.
This is the 2st pthread,created by zieckey.
This is the 1st pthread,created by zieckey.
....

兩個(gè)線程交替執(zhí)行。
此例子介紹了創(chuàng)建線程的方法。
下面例子介紹向線程傳遞參數(shù)。

例程2：
??? 功能：向新的線程傳遞整形值
??? 程序名稱：pthread_int.c
/********************************************************************************************
**??? Name:pthread_int.c
**??? Used to study the multithread programming in Linux OS
**??? Pass a parameter to the thread.
**??? Author:zeickey
**??? Date:2006/9/16????? ?
**??? Copyright (c) 2006,All Rights Reserved!
*********************************************************************************************/

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

void *create(void *arg)
{
??? int *num;
??? num=(int *)arg;
??? printf("create parameter is %d /n",*num);
??? return (void *)0;
}
int main(int argc ,char *argv[])
{
??? pthread_t tidp;
??? int error;
? ?
??? int test=4;
??? int *attr=&test;
? ?
??? error=pthread_create(&tidp,NULL,create,(void *)attr);

??? if(error)
??????? {
??????? printf("pthread_create is created is not created ... /n");
??????? return -1;
??????? }
??? sleep(1);
??? printf("pthread_create is created .../n");
??? return 0;????? ?
}

??? 編譯方法：

gcc -lpthread pthread_int.c -Wall

??? 執(zhí)行結(jié)果：

create parameter is 4
pthread_create is created is? created ...

??? 例程總結(jié)：
??? 可以看出來，我們在main函數(shù)中傳遞的整行指針，傳遞到我們新建的線程函數(shù)中。
??? 在上面的例子可以看出來我們向新的線程傳入了另一個(gè)線程的int數(shù)據(jù)，線程之間還可以傳遞字符串或是更復(fù)雜的數(shù)據(jù)結(jié)構(gòu)。

例程3：
??? 程序功能：向新建的線程傳遞字符串
??????? 程序名稱：pthread_string.c
/********************************************************************************************
**??? Name:pthread_string.c
**??? Used to study the multithread programming in Linux OS
**??? Pass a ‘char*‘ parameter to the thread.
**??? Author:zeickey
**??? Date:2006/9/16????? ?
**??? Copyright (c) 2006,All Rights Reserved!
*********************************************************************************************/
#include <pthread.h>
#include <stdio.h>
#include <unistd.h>

void *create(void *arg)
{
??? char *name;
??? name=(char *)arg;
??? printf("The parameter passed from main function is %s? /n",name);
??? return (void *)0;
}

int main(int argc, char *argv[])
{
??? char *a="zieckey";
??? int error;
??? pthread_t tidp;

??? error=pthread_create(&tidp, NULL, create, (void *)a);

??? if(error!=0)
??? {
??????? printf("pthread is not created./n");
??????? return -1;
??? }
??? sleep(1);
??? printf("pthread is created... /n");
??? return 0;
}? ?

? 編譯方法：

gcc -Wall pthread_string.c -lpthread

??? 執(zhí)行結(jié)果：
The parameter passed from main function is zieckey
pthread is created...

??? 例程總結(jié)：
??? 可以看出來main函數(shù)中的字符串傳入了新建的線程中。

例程4：
??? 程序功能：向新建的線程傳遞字符串
??????? 程序名稱：pthread_struct.c
/********************************************************************************************
**??? Name:pthread_struct.c
**??? Used to study the multithread programming in Linux OS
**??? Pass a ‘char*‘ parameter to the thread.
**??? Author:zeickey
**??? Date:2006/9/16????? ?
**??? Copyright (c) 2006,All Rights Reserved!
*********************************************************************************************/
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <stdlib.h>

struct menber
{
??? int a;
??? char *s;
};

void *create(void *arg)
{
??? struct menber *temp;
??? temp=(struct menber *)arg;
??? printf("menber->a = %d? /n",temp->a);
??? printf("menber->s = %s? /n",temp->s);
??? return (void *)0;
}

int main(int argc,char *argv[])
{
??? pthread_t tidp;
??? int error;
??? struct menber *b;
??? b=(struct menber *)malloc( sizeof(struct menber) );
??? b->a = 4;
??? b->s = "zieckey";

??? error = pthread_create(&tidp, NULL, create, (void *)b);

??? if( error )
??? {
??????? printf("phread is not created.../n");
??????? return -1;
??? }
??? sleep(1);
??? printf("pthread is created.../n");
??? return 0;
}

? 編譯方法：

gcc -Wall pthread_struct.c -lpthread

??? 執(zhí)行結(jié)果：
menber->a = 4
menber->s = zieckey
pthread is created...

??? 例程總結(jié)：
??? 可以看出來main函數(shù)中的一個(gè)結(jié)構(gòu)體傳入了新建的線程中。
??? 線程包含了標(biāo)識(shí)進(jìn)程內(nèi)執(zhí)行環(huán)境必須的信息。他集成了進(jìn)程中的所有信息都是對線程進(jìn)行共享的，包括文本程序、程序的全局內(nèi)存和堆內(nèi)存、棧以及文件描述符。
? ?

例程5：
??? 程序目的：驗(yàn)證新建立的線程可以共享進(jìn)程中的數(shù)據(jù)
??? 程序名稱：pthread_share.c

/********************************************************************************************
**??? Name:pthread_share_data.c
**??? Used to study the multithread programming in Linux OS
**??? Pass a ‘char*‘ parameter to the thread.
**??? Author:zeickey
**??? Date:2006/9/16????? ?
**??? Copyright (c) 2006,All Rights Reserved!
*********************************************************************************************/
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

static int a=4;
void *create(void *arg)
{
??? printf("new pthread ... /n");
??? printf("a=%d? /n",a);
??? return (void *)0;
}

int main(int argc,char *argv[])
{
??? pthread_t tidp;
??? int error;
? ?
??? a=5;

??? error=pthread_create(&tidp, NULL, create, NULL);

??? if(error!=0)
??? {
??????? printf("new thread is not create ... /n");
??????? return -1;
??? }
? ?
??? sleep(1);
? ?
??? printf("new thread is created ... /n");
??? return 0;
}
? ?
? 編譯方法：

gcc -Wall pthread_share_data.c -lpthread

??? 執(zhí)行結(jié)果：
new pthread ...
a=5
new thread is created ...

??? 例程總結(jié)：
可以看出來，我們在主線程更改了我們的全局變量a的值的時(shí)候，我們新建立的線程則打印出來了改變的值，可以看出可以訪問線程所在進(jìn)程中的數(shù)據(jù)信息。

???????? 2、線程的終止

??? 如果進(jìn)程中任何一個(gè)線程中調(diào)用exit，_Exit,或者是_exit，那么整個(gè)進(jìn)程就會(huì)終止，
??? 與此類似，如果信號的默認(rèn)的動(dòng)作是終止進(jìn)程，那么，把該信號發(fā)送到線程會(huì)終止進(jìn)程。
??? 線程的正常退出的方式：
?????? (1) 線程只是從啟動(dòng)例程中返回，返回值是線程中的退出碼
?????? (2) 線程可以被另一個(gè)進(jìn)程進(jìn)行終止
?????? (3) 線程自己調(diào)用pthread_exit函數(shù)
??? 兩個(gè)重要的函數(shù)原型：

#include <pthread.h>
void pthread_exit(void *rval_ptr);
/*rval_ptr 線程退出返回的指針*/

int pthread_join(pthread_t thread,void **rval_ptr);
?? /*成功結(jié)束進(jìn)程為0,否則為錯(cuò)誤編碼*/

??? 例程6
??? 程序目的：線程正常退出，接受線程退出的返回碼
??? 程序名稱：pthread_exit.c

/********************************************************************************************
**??? Name:pthread_exit.c
**??? Used to study the multithread programming in Linux OS
**??? A example showing a thread to exit and with a return code.
**??? Author:zeickey
**??? Date:2006/9/16?????? ?
**??? Copyright (c) 2006,All Rights Reserved!
*********************************************************************************************/

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

void *create(void *arg)
{
??? printf("new thread is created ... /n");
??? return (void *)8;
}

int main(int argc,char *argv[])
{
??? pthread_t tid;
??? int error;
??? void *temp;

??? error = pthread_create(&tid, NULL, create, NULL);

??? if( error )
??? {
??????? printf("thread is not created ... /n");
??????? return -1;
??? }
??? error = pthread_join(tid, &temp);

??? if( error )
??? {
??????? printf("thread is not exit ... /n");
??????? return -2;
??? }
?? ?
??? printf("thread is exit code %d /n", (int )temp);
??? return 0;
}

? 編譯方法：

gcc -Wall pthread_exit.c -lpthread

??? 執(zhí)行結(jié)果：
new thread is created ...
thread is exit code 8

??? 例程總結(jié)：
可以看出來，線程退出可以返回線程的int數(shù)值。線程退出不僅僅可以返回線程的int數(shù)值，還可以返回一個(gè)復(fù)雜的數(shù)據(jù)結(jié)構(gòu)。

??? 例程7
??? 程序目的：線程結(jié)束返回一個(gè)復(fù)雜的數(shù)據(jù)結(jié)構(gòu)
??? 程序名稱：pthread_return_struct.c
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

struct menber
{
??? int a;
??? char *b;
}temp={8,"zieckey"};
void *create(void *arg)
{
??? printf("new thread ... /n");
??? return (void *)&temp;
}

int main(int argc,char *argv[])
{
??? int error;
??? pthread_t tid;
??? struct menber *c;

??? error = pthread_create(&tid, NULL, create, NULL);
? ?
??? if( error )
??? {
??????? printf("new thread is not created ... /n");
??????? return -1;
??? }
??? printf("main ... /n");

??? error = pthread_join(tid,(void *)&c);

??? if( error )
??? {
??????? printf("new thread is not exit ... /n");
??????? return -2;
??? }
??? printf("c->a = %d? /n",c->a);
??? printf("c->b = %s? /n",c->b);
??? sleep(1);
??? return 0;
}

? 編譯方法：

gcc -Wall pthread_return_struct.c -lpthread

??? 執(zhí)行結(jié)果：

main ...
new thread ...
c->a = 8
c->b = zieckey

例程總結(jié)：
一定要記得返回的數(shù)據(jù)結(jié)構(gòu)要是在這個(gè)數(shù)據(jù)要返回的結(jié)構(gòu)沒有釋放的時(shí)候應(yīng)用，
如果數(shù)據(jù)結(jié)構(gòu)已經(jīng)發(fā)生變化，那返回的就不會(huì)是我們所需要的，而是臟數(shù)據(jù)
3、線程標(biāo)識(shí)

??? 函數(shù)原型：
? ?
#include <pthread.h>
pthread_t pthread_self(void);

pid_t getpid(void);
??? getpid()用來取得目前進(jìn)程的進(jìn)程識(shí)別碼,函數(shù)說明

??? 例程8
??? 程序目的：實(shí)現(xiàn)在新建立的線程中打印該線程的id和進(jìn)程id
??? 程序名稱：pthread_id.c
?
/********************************************************************************************
**??? Name:pthread_id.c
**??? Used to study the multithread programming in Linux OS.
**??? Showing how to get the thread's tid and the process's pid.
**??? Author:zeickey
**??? Date:2006/9/16????? ?
**??? Copyright (c) 2006,All Rights Reserved!
*********************************************************************************************/
#include <stdio.h>
#include <pthread.h>
#include <unistd.h> /*getpid()*/

void *create(void *arg)
{
??? printf("New thread .... /n");
??? printf("This thread's id is %u? /n", (unsigned int)pthread_self());
??? printf("The process pid is %d? /n",getpid());
??? return (void *)0;
}

int main(int argc,char *argv[])
{
??? pthread_t tid;
??? int error;

??? printf("Main thread is starting ... /n");

??? error = pthread_create(&tid, NULL, create, NULL);

??? if(error)
??? {
??????? printf("thread is not created ... /n");
??????? return -1;
??? }
??? printf("The main process's pid is %d? /n",getpid());
??? sleep(1);
??? return 0;
}

??? 編譯方法：

?
gcc -Wall -lpthread pthread_id.c

??? 執(zhí)行結(jié)果：

Main thread is starting ...
The main process's pid is 3307
New thread ....
This thread's id is 3086347152
The process pid is 3307

介紹linux線程的基本概念，線程間的互斥和同步機(jī)制，分析了linuxpthread庫的API函數(shù)，并結(jié)合一個(gè)例子闡述多線程編程的核心技術(shù)，最后總結(jié)出多線程編程應(yīng)注意的事項(xiàng)。

關(guān)鍵詞 線程進(jìn)程同步互斥中圖分類號：TP316 文獻(xiàn)標(biāo)識(shí)碼：A 1．引言 目前,許多流行的多任務(wù)操作系統(tǒng)都提供線程機(jī)制,線程就是程序中的單個(gè)順序控制流。利用多線程進(jìn)行程序設(shè)計(jì),就是將一個(gè)程序(進(jìn)程)的任務(wù)劃分為執(zhí)行的多個(gè)部分(線程) ,每一個(gè)線程為一個(gè)順序的單控制流,而所有線程都是并發(fā)執(zhí)行的,這樣,多線程程序就可以實(shí)現(xiàn)并行計(jì)算,高效利用多處理器。線程可分為用戶級線程和內(nèi)核級線程兩種基本類型。用戶級線程不需要內(nèi)核支持,可以在用戶程序中實(shí)現(xiàn),線程調(diào)度、同步與互斥都需要用戶程序自己完成。內(nèi)核級線程需要內(nèi)核參與,由內(nèi)核完成線程調(diào)度并提供相應(yīng)的系統(tǒng)調(diào)用,用戶程序可以通過這些接口函數(shù)對線程進(jìn)行一定的控制和管理。Linux操作系統(tǒng)提供了LinuxThreads庫，它是符合POSIX1003.1c標(biāo)準(zhǔn)的內(nèi)核級多線程函數(shù)庫。在linuxthreads庫中提供了一些多線程編程的關(guān)鍵函數(shù)，在多線程編程時(shí)應(yīng)包括pthread.h文件。 2.LinuxThread中的關(guān)鍵庫函數(shù) 2.1線程的創(chuàng)建和終止 int pthread_create(pthread_t * pthread,const pthread_attr_t *attr,void *(*start_routine(*void)),void *arg);調(diào)用此函數(shù)可以創(chuàng)建一個(gè)新的線程，新線程創(chuàng)建后執(zhí)行start_routine 指定的程序。其中參數(shù)attr是用戶希望創(chuàng)建線程的屬性，當(dāng)為NULL時(shí)表示以默認(rèn)的屬性創(chuàng)建線程。arg是向start_routine 傳遞的參數(shù)。當(dāng)成功創(chuàng)建一個(gè)新的線程時(shí)，系統(tǒng)會(huì)自動(dòng)為新線程分配一個(gè)線程ID號，并通過pthread 返回給調(diào)用者。 void pthread_exit(void *value_ptr);調(diào)用該函數(shù)可以退出線程，參數(shù)value_ptr是一個(gè)指向返回狀態(tài)值的指針。 2.2線程控制函數(shù) pthread_self(void);為了區(qū)分線程，在線程創(chuàng)建時(shí)系統(tǒng)為其分配一個(gè)唯一的ID號，由pthread_create()返回給調(diào)用者，也可以通過pthread_self()獲取自己的線程ID。 Int pthread_join (pthread- t thread , void * *status);這個(gè)函數(shù)的作用是等待一個(gè)線程的結(jié)束。調(diào)用pthread_join()的線程將被掛起直到線程ID為參數(shù)thread 指定的線程終止。 int pthread_detach(pthread_t pthread);參數(shù)pthread代表的線程一旦終止，立即釋放調(diào)該線程占有的所有資源。 2.3線程間的互斥互斥量和臨界區(qū)類似，只有擁有互斥量的線程才具有訪問資源的權(quán)限，由于互斥對象只有一個(gè)，這就決定了任何情況下共享資源（代碼或變量）都不會(huì)被多個(gè)線程同時(shí)訪問。使用互斥不僅能夠在同一應(yīng)用程序的不同線程中實(shí)現(xiàn)資源的安全共享，而且可以在不同應(yīng)用程序的線程之間實(shí)現(xiàn)對資源的安全共享。Linux中通過pthread_mutex_t來定義互斥體機(jī)制完成互斥操作。具體的操作函數(shù)如下 pthread_mutex_init(pthread_mutex_t *mutex,const pthread_mutexattr_t *attr);初使化一個(gè)互斥體變量mutex，參數(shù)attr表示按照attr屬性創(chuàng)建互斥體變量mutex，如果參數(shù)attr為NULL，則以默認(rèn)的方式創(chuàng)建。 pthread_mutex_lock(pthread_mutex_t *mutex);給一個(gè)互斥體變量上鎖，如果mutex指定的互斥體已經(jīng)被鎖住，則調(diào)用線程將被阻塞直到擁有mutex的線程對mutex解鎖為止。 Pthread_mutex_unlock(pthread_mutex_t *mutex);對參數(shù)mutex指定的互斥體變量解鎖。 2.4線程間的同步同步就是線程等待某一個(gè)事件的發(fā)生，當(dāng)?shù)却氖录l(fā)生時(shí)，被等待的線程和事件一起繼續(xù)執(zhí)行。如果等待的事件未到達(dá)則掛起。在linux操作系統(tǒng)中是通過條件變量來實(shí)現(xiàn)同步的。 Pthread_cond_init(pthread_cond_t *cond,const pthread_cond_t *attr);這個(gè)函數(shù)按參數(shù)attr指定的屬性初使化一個(gè)條件變量cond。 Pthread_cond_wait(pthread_cond_t *cond,pthread_mutex_t *mutex);等待一個(gè)事件（條件變量）的發(fā)生，發(fā)出調(diào)用的線程自動(dòng)阻塞，直到相應(yīng)的條件變量被置1。等待狀態(tài)的線程不占用CPU時(shí)間。 pthread_cond_signal(pthread_cond_t *cond);解除一個(gè)等待參數(shù)cond指定的條件變量的線程的阻塞狀態(tài)。 3．多線程編程的應(yīng)用實(shí)例。 在這里利用多線程技術(shù)實(shí)現(xiàn)生產(chǎn)者和消費(fèi)者問題，生產(chǎn)者線程向一緩沖區(qū)中寫數(shù)據(jù)，消費(fèi)者線程從緩沖區(qū)中讀取數(shù)據(jù)，由于生產(chǎn)者線程和消費(fèi)者線程共享同一緩沖區(qū)，為了正確讀寫數(shù)據(jù)，在使用緩沖隊(duì)列時(shí)必須保持互斥。生產(chǎn)者線程和消費(fèi)者線程必須滿足：生產(chǎn)者寫入緩沖區(qū)的數(shù)目不能超過緩沖區(qū)容量，消費(fèi)者讀取的數(shù)目不能超過生產(chǎn)者寫入的數(shù)目。在程序中使用了一個(gè)小技巧來判斷緩沖區(qū)是空還是滿。在初始化時(shí)讀指針和寫指針為0;如果讀指針等于寫指針,則緩沖區(qū)是空的;如果(寫指針+ 1) % N 等于讀指針,則緩沖區(qū)是滿的,%表示取余數(shù),這時(shí)實(shí)際上有一個(gè)單元空出未用。下面是完整的程序段和注釋。

#include<stdio.h>
#include<pthread.h>

#define BUFFER_SIZE 8

struct prodcons {
??? int buffer[BUFFER_SIZE];
??? pthread_mutex_t lock;????? //互斥LOCK
??? int readpos , writepos;
??? pthread_cond_t notempty;?? //緩沖區(qū)非空條件判斷
??? pthread_cond_t notfull;??? //緩沖區(qū)未滿條件判斷
};

void init(struct prodcons * b){
??? pthread_mutex_init(&b->lock,NULL);
??? pthread_cond_init(&b->notempty,NULL);
??? pthread_cond_init(&b->notfull,NULL);

??? b->readpos=0;
??? b->writepos=0;
}

void put(struct prodcons* b,int data){
??? pthread-_mutex_lock(&b->lock);

??? if((b->writepos + 1) % BUFFER_SIZE == b->readpos)
??? {
??????? pthread_cond_wait(&b->notfull, &b->lock) ;
??? }
???
??? b->buffer[b->writepos]=data;
??? b->writepos++;
???
??? if(b->writepos >= BUFFER_SIZE)
??????? b->writepos=0;
???
??? pthread_cond_signal(&b->notempty);
??? pthread_mutex_unlock(&b->lock);
}
int get(struct prodcons *b){
??? int data;

??? pthread_mutex_lock(&b->lock);
??? if(b->writepos == b->readpos)
??? {
??????? pthread_cond _wait(&b->notempty, &b->lock);
??? }
???
??? data = b->buffer[b->readpos];
??? b->readpos++;

??? if(b->readpos >= BUFFER_SIZE)
??????? b->readpos=0;
???
??? pthread_cond_signal(&b->notfull);
??? pthread_mutex_unlock(&b->lock);

??? return data;
}

#define OVER (-1)
struct prodcons buffer;

void *producer(void *data)
{
??? int n;
???
??? for(n = 0; n < 10000; n++)
??? {
??????? printf("%d \n", n) ;
??????? put(&buffer, n);
??? }
???
??? put(&buffer, OVER);
???
??? return NULL;
}
void *consumer(void * data)
{
??? int d;
???
??? while(1)
??? {
??????? d = get(&buffer);

??????? if(d == OVER)
??????????? break;
???????
??????? printf("%d\n", d);
??? }

??? return NULL;
}

int main(void)
{
??? pthread_t th_a, th_b;
???
??? void *retval;
???
??? init(&buffer);
???
??? pthread_create(&th_a, NULL, producer, 0);
??? pthread_create(&th_b, NULL, consumer, 0);
???
??? pthread_join(th_a, &retval);
??? pthread_join(th_b, &retval);
???
??? return 0;
}

上面的例子中，生產(chǎn)者負(fù)責(zé)將1到1000的整數(shù)寫入緩沖區(qū)，而消費(fèi)者負(fù)責(zé)從同一個(gè)緩沖區(qū)中讀取寫入的整數(shù)并打印出來。因?yàn)樯a(chǎn)者和消費(fèi)者是兩個(gè)同時(shí)運(yùn)行的線程，并且要使用同一個(gè)緩沖區(qū)進(jìn)行數(shù)據(jù)交換，因此必須利用一種機(jī)制進(jìn)行同步。通過上面的例子我們可以看到，多線程的最大好處是，除堆棧之外，幾乎所有的數(shù)據(jù)均是共享的，因此線程間的通訊效率很高；缺點(diǎn)：因?yàn)楣蚕硭袛?shù)據(jù)，從而非常容易導(dǎo)致線程之間互相破壞數(shù)據(jù)，這一點(diǎn)在編程時(shí)必須注意。 4.結(jié)束語 Linux中基于POSIX標(biāo)準(zhǔn)的很好的支持了多線程技術(shù)，它減少了程序并發(fā)執(zhí)行時(shí)的系統(tǒng)開銷,提高了計(jì)算機(jī)的工作效率。在具體編程過程中要了解線程的間的關(guān)系,還要考慮共享數(shù)據(jù)的保護(hù),在互斥和同步機(jī)制下保證代碼的高效運(yùn)行，程序編譯時(shí)用gcc -D –REENTRANT -libpthread.xx.so filename.c編譯。

轉(zhuǎn)載于:https://www.cnblogs.com/james1207/p/3299413.html

總結(jié)

以上是生活随笔為你收集整理的linux中多线程解析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。

上一篇： [移动网关]2G环境下资源下载有一定概率
下一篇： Django model反向关联名称的方