av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術(shù)文章
文章詳情頁

linux - 如何理解互斥鎖和條件變量?

瀏覽:102日期:2024-06-14 11:33:23

問題描述

下面的代碼出自《Unix/Linux編程實(shí)踐教程》,作用是用兩個(gè)線程分別統(tǒng)計(jì)兩個(gè)文件的單詞的數(shù)目,并在主線程中計(jì)算總數(shù)。下面是運(yùn)行截圖:

linux - 如何理解互斥鎖和條件變量?

但是看了半天還是難以理解下面代碼中的加鎖、解鎖以及條件變量。我想問:

主線程中調(diào)用pthread_cond_wait時(shí)會(huì)釋放互斥鎖,然后掛起主線程,并等待條件變量的發(fā)生變化,當(dāng)其他線程調(diào)用pthread_cond_signal時(shí),如果互斥鎖是被鎖住的,那么主線程中的pthread_cond_wait會(huì)等互斥待鎖被解鎖后,然后再給互斥鎖上鎖后再返回嗎?

如果正如1中的描述那樣的話,pthread_cond_wait收到了pthread_cond_signal發(fā)來的信號(hào),但是未鎖定互斥鎖之前,又被其他線程搶了先,鎖住了互斥鎖,那不是pthread_cond_wait還得掛起等待互斥鎖被解鎖?

如果可以的話,希望能幫助理清一下這個(gè)程序的執(zhí)行流程。

萬分感謝。

#include <stdio.h>#include <stdlib.h>#include <pthread.h>#include <ctype.h>struct arg_set { /* two values int one arg */ char *filename; /* file to examine */ int count; /* number of words */ int code;};struct arg_set *mailbox = NULL;pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;pthread_cond_t flag = PTHREAD_COND_INITIALIZER;void *count_words(void *);int main(int argc, char *argv[]){ pthread_t t1, t2; /* two threads */ struct arg_set args1, args2; /* two argsets */ int reports_int = 0; int total_words = 0; if (argc != 3) {fprintf(stderr, 'usage: %s file1 file2', argv[0]);exit(1); } pthread_mutex_lock(&lock); args1.filename = argv[1]; args1.count = 0; args1.code = 1; pthread_create(&t1, NULL, count_words, (void *)&args1); args2.filename = argv[2]; args2.count = 0; args2.code = 2; pthread_create(&t2, NULL, count_words, (void *)&args2); while (reports_int < 2) { // 等待其他線程結(jié)束printf('MAIN: waiting for flag to go upn');pthread_cond_wait(&flag, &lock);printf('MAIN: Wow! flag was raised, I have the lockn');printf('%7d: %sn', mailbox->count, mailbox->filename);total_words += mailbox->count;if (mailbox == &args1) pthread_join(t1, NULL);if (mailbox == &args2) pthread_join(t2, NULL);mailbox = NULL;pthread_cond_signal(&flag);reports_int++; } printf('%7d: total wordsn', total_words); return 0;}void *count_words(void *a){ struct arg_set *args = a; FILE *fp; int c, prevc = ’0’; if ((fp = fopen(args->filename, 'r')) != NULL) { // 統(tǒng)計(jì)單詞個(gè)數(shù)while ((c = getc(fp)) != EOF) { if (!isalnum(c) && isalnum(prevc))args->count++; prevc = c;}fclose(fp); } elseperror(args->filename); printf('COUNT %d: waiting to get lockn', args->code); pthread_mutex_lock(&lock); printf('COUNT %d: have lock, storing datan', args->code); if (mailbox != NULL)pthread_cond_wait(&flag, &lock); mailbox = args; printf('COUNT %d: raising flagn', args->code); pthread_cond_signal(&flag); printf('COUNT %d: unlocking boxn', args->code); pthread_mutex_unlock(&lock); return NULL;}

問題解答

回答1:

沒什么復(fù)雜的,主線程獲得鎖后,進(jìn)入休眠,等一個(gè)信號(hào)來喚醒它。

pthread_cond_signal就是這個(gè)信號(hào)

這種鎖與別的鎖有點(diǎn)不同,其它類型的鎖是:線程申請(qǐng)鎖,沒有得到鎖,線程就進(jìn)入休眠,等待。

這種鎖是有鎖就休眠,等別的線程叫醒它。

相關(guān)文章:
主站蜘蛛池模板: av一区二区三区在线观看 | 国产天堂在线 | 亚洲国产网站 | 国产精品视频久久久 | av片免费 | 九一九色国产 | 人人看av| 日韩中文字幕在线视频 | 成人在线视频免费 | 日韩黄色小视频 | 久久精品一 | 91青青草| 精品无人国产偷自产在线 | 91成人免费 | 欧美久久久久久久久 | 亚洲日本视频 | 天天摸夜夜操 | 一级片在线播放 | 国产三级在线免费观看 | 免费一级大片 | 国产小视频在线播放 | 亚洲精品视频在线 | 亚洲精品成人在线 | 中文字幕免费 | 一区二区不卡视频 | 日韩在线免费观看视频 | 亚洲精品网站在线观看 | 国产精品1234| 欧美日韩在线一区二区三区 | 国产在线视频一区 | 国产伦精品一区二区三区四区免费 | 欧美一级做性受免费大片免费 | 欧美国产在线观看 | 中文一级片 | 中文久久久 | 欧美在线视频观看 | 亚洲国产成人精品女人 | 欧美特黄视频 | 日韩av在线免费看 | 亚洲欧美一区二区三区在线 | 欧美精品久久久久久久多人混战 |