多线程操作
而linux中sleep(3000)是3000秒。
實(shí)現(xiàn)多線程程序,一個(gè)線程打印3的倍數(shù),另一個(gè)線程打印剩下數(shù)字
應(yīng)該要用條件變量實(shí)現(xiàn),條件變量一定要和互斥量連用
信號(hào)量與Mutex最大的不同是,Mutex只能被acquire它的線程release, 可semaphore可以被不同的線程release
如果是本線程對(duì)互斥量加鎖,則只能由本線程解鎖
pthread_cond_wait ()和pthread_cond_timedwait()都被實(shí)現(xiàn)為取消點(diǎn),因此,在該處等待的線程將立即重新運(yùn)行,在重新鎖定mutex后離開 pthread_cond_wait(),然后執(zhí)行取消動(dòng)作。也就是說如果pthread_cond_wait()被取消,mutex是保持鎖定狀態(tài)的,因而需要定義退出回調(diào)函數(shù)來為其解鎖。
pthread_cond_wait實(shí)際上可以看作是以下幾個(gè)動(dòng)作的合體:
解鎖線程鎖;
等待條件為true;
加鎖線程鎖;
使用形式:
// 線程一代碼
pthread_mutex_lock(&mutex);
if (條件滿足)
pthread_cond_signal(&cond);//即使在線程1中發(fā)送了cond,線程二收到了cond,但是此時(shí)線程二要堵塞到pthread_cond_wait內(nèi)部的加鎖,也就是說只有線程一unlock mutex之后,線程二才能在pthread_cond_wait函數(shù)內(nèi)部加鎖后繼續(xù)運(yùn)行
pthread_mutex_unlock(&mutex);
//也就只有在這個(gè)模塊之后,線程二的代碼才可能在滿足條件的情況下運(yùn)行
// 線程二代碼
pthread_mutex_lock(&mutex);
while (條件不滿足)
pthread_cond_wait(&cond, &mutex);
pthread_mutex_unlock(&mutex);
/*線程二中為什么使用while呢?因?yàn)樵趐thread_cond_signal和pthread_cond_wait返回之間,有時(shí)間差,假設(shè)在這個(gè)時(shí)間差內(nèi),條件改變了,顯然需要重新檢查條件。也就是說在pthread_cond_wait被喚醒的時(shí)候可能該條件已經(jīng)不成立。*/
#include <pthread.h> #include <stdio.h> #include <stdlib.h> #include<unistd.h>pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; /*初始化互斥鎖*/ pthread_cond_t cond = PTHREAD_COND_INITIALIZER; //初始化條件變量 pthread_cond_t cond1 = PTHREAD_COND_INITIALIZER; //初始化條件變量 const int N = 100; void *thread1(void *); void *thread2(void *);int i=1; int main() {pthread_t t_a;pthread_t t_b;pthread_create(&t_a,NULL,thread1,(void *)NULL);//創(chuàng)建進(jìn)程t_apthread_create(&t_b,NULL,thread2,(void *)NULL); //創(chuàng)建進(jìn)程t_bpthread_join(t_b, NULL);//等待進(jìn)程t_b結(jié)束pthread_mutex_destroy(&mutex);pthread_cond_destroy(&cond);return 0; }void *thread1(void *junk) {for(;i<=N;){pthread_mutex_lock(&mutex);//while(i%3==0){pthread_cond_signal(&cond);//通知線程2打印pthread_cond_wait(&cond1,&mutex);//當(dāng)收到cond1時(shí)才取消堵塞}//線程1主要打印非3的倍數(shù)的數(shù)字printf("thead1:%d\n",i);++i;pthread_mutex_unlock(&mutex);//*解鎖互斥量*/}}void *thread2(void *junk) {while(i<N){pthread_mutex_lock(&mutex);while(i%3!=0){pthread_cond_signal(&cond1);pthread_cond_wait(&cond,&mutex);/*等待*/}printf("thread2:%d\n",i);++i;pthread_mutex_unlock(&mutex);}}
g++ -lpthread cond.cpp -o mutex
在boost或者c#中還有一種更為簡單直接的加鎖方式,就是關(guān)鍵域。
在每個(gè)線程都執(zhí)行同一段代碼,在這段代碼的上下加鎖,一次只能進(jìn)入一個(gè)線程處理
一個(gè)不太雅觀的說法是:
CriticalSection(臨界區(qū)) 類似于只有一個(gè)蹲位的公共廁所, 只能一個(gè)個(gè)地進(jìn);
Mutex(互斥) 對(duì)象類似于接力賽中的接力棒, 某一時(shí)刻只能一個(gè)人持有, 誰拿著誰跑.
每一個(gè)子線程都要執(zhí)行同樣的函數(shù),在這個(gè)函數(shù)中的公共資源的要放入臨界區(qū)內(nèi)
總結(jié)
- 上一篇: 库壳的一些有趣面试题
- 下一篇: 多线程生产者和消费者