线程的同步机制(互斥锁,条件变量,信号量,读写锁,自旋锁)

互斥锁

  • 初始化
#inlude <pthread.h>
int pthread_mutex_init(pthread_mutex_t *restrict mutex,
const pthread_mutexattr_t *restrict attr);

attr锁属性非NULL时:
PTHREAD_MUTEX_TIMED_NP:普通锁
PTHREAD_MUTEX_RECURSIVE_NP:嵌套锁(同一锁可多次加锁)
PTHREAD_MUTEX_ERRORCHECK_NP:检错锁
PTHREAD_MUTEX_ADAPTIVE_NP:适应锁,释放后重新竞争

  • 销毁
#inlude <pthread.h>
int pthread_mutex_destroy(pthread_mutex_t *mutex);
  • 申请互斥锁(加锁)
#inlude <pthread.h>
int pthread_mutex_lock(pthread_mutex_t *mutex);//没成功(已被加锁)就阻塞
int pthread_mutex_trylock(pthread_mutex_t *mutex);//没成功(已被加锁)就返回
  • 释放互斥锁(解锁)
#inlude <pthread.h>
int pthread_mutex_unlock(pthread_mutex_t *mutex);
示例代码:
#include <pthread.h>
#include <unistd.h>
#include <iostream>
using namespace std;

pthread_mutex_t mutex;

int sum=0;
void *fun1(void *arg)
{
    int i=5;
    pthread_mutex_lock(&mutex);
    

    while(i>0){
        sleep(1);
        cout<<"thread1"<<endl;
        i--;
        sum++;  
    }
    pthread_mutex_unlock(&mutex);
}

void *fun2(void *arg)
{
    int i=5;
    pthread_mutex_lock(&mutex);
    

    while(i>0){
        sleep(1);
        cout<<"thread2"<<endl;
        i--;
        sum--;  
    }
    pthread_mutex_unlock(&mutex);
}

int main()
{
    pthread_t thread1,thread2;
    pthread_mutex_init(&mutex,NULL);
    pthread_create(&thread1,NULL,fun1,NULL);
    pthread_create(&thread2,NULL,fun2,NULL);

    pthread_join(thread1,NULL);
    pthread_join(thread2,NULL);
    pthread_mutex_destroy(&mutex);
    cout << "sum= "<<sum <<endl;
    return 0;
}

运行结果:



若将加锁解锁注释掉后运行结果


条件变量

若有一个临界资源如一个缓冲区(字符数组),当缓冲区为空时线程A写数据,当缓冲区有数据时B取出数据。此时光靠互斥锁不能满足要求,就需要Linux另一个同步机制----条件变量。

  • 初始化
#include <pthread.h>
int pthread_cond_init(pthread_cond_t *restrict cond,
const pthread_condattr_t *restrict attr);
  • 销毁
#include <pthread.h>
int pthread_cond_destroy(pthread_cond_t *cond);
  • 阻塞等待条件变量(p操作)
#include <pthread.h>
int pthread_cond_wait(pthread_cond_t *restrict cond,
pthread_mutex_t *restrict mutex);
int pthread_cond_timedwait(pthread_cond_t *restrict cond,
pthread_mutex_t *restrict mutex,
const struct timespec *restrict abstime);//在指定时间之内等待

wait在调用的时候, 这个线程会释放mutex, 并且给这个cond上锁, 线程被挂起, 不占用CPU,被唤醒的时候这个抢到锁线程会自动重新上锁 —— 即重新获得mutex

无论哪种等待方式,都必须和一个互斥锁配合,以防止多个线程同时请求pthread_cond_wait()(或pthread_cond_timedwait(),下同)的竞争条件(Race Condition)。mutex互斥锁必须是普通锁(PTHREAD_MUTEX_TIMED_NP)或者适应锁(PTHREAD_MUTEX_ADAPTIVE_NP),且在调用pthread_cond_wait()前必须由本线程加锁(pthread_mutex_lock()),而在更新条件等待队列以前,mutex保持锁定状态,并在线程挂起进入等待前解锁。在条件满足从而离开pthread_cond_wait()之前,mutex将被重新加锁,以与进入pthread_cond_wait()前的加锁动作对应。
————————————————
版权声明:本文为CSDN博主「猫已经找不回了」的原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/hairetz/java/article/details/4535920

  • 互斥锁加条件变量使用过程
    1. 临界区加锁
    2. 挂起等待,等待时释放锁
    3. 被唤醒,加锁,进入临界区
    4. 退出临界区时减锁。
      挂起前后锁的变化:挂起等待前加锁,挂起等待时解锁,被唤醒时解锁
  • 通知等待该条件变量的线程(v操作)
int pthread_cond_signal(pthread_cond_t *cond);
int pthread_cond_broadcast(pthread_cond_t *cond);//广播通知

示例代码
用条件变量和互斥锁解决生产者消费者问题

#include<iostream>
#include<unistd.h>
#include<stdlib.h>
#include<pthread.h>

using namespace std;

static int count = 0;
// 对于这些pthread中的type要么使用init初始化, 要么使用系统宏初始化
static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
static pthread_cond_t cond_not_full = PTHREAD_COND_INITIALIZER;
static pthread_cond_t cond_not_empty = PTHREAD_COND_INITIALIZER;

void *produce(void *arg) {
    while(1) {
        pthread_mutex_lock(&mutex);

        /*
        这里写上while是没有错的, 这是因为当其他的线程调用signal的时候, 可能会有多个线程同时被唤醒, 但是由于只有一个线程才可以拿到锁, 其他的还是需要继续wait, 所以为了避免“惊群效应”, 同时也为了维护同一个时刻只有一个线程可以进入临界区, 这里使用while
        */
        while(count >= 10) {
            pthread_cond_wait(&cond_not_full, &mutex);
        }

        ++count;
        cout << "produce: count = " << count << endl;
        pthread_mutex_unlock(&mutex);
        pthread_cond_signal(&cond_not_empty);
    }

    return NULL;
}

void *consume(void *arg) {
    while(1) {
        pthread_mutex_lock(&mutex);

        while(count <= 0) {
            pthread_cond_wait(&cond_not_empty, &mutex);
        }

        --count;
        cout << "consume: count = " << count << endl;
        pthread_mutex_unlock(&mutex);
        pthread_cond_signal(&cond_not_full);
    }

    return NULL;
}

int main() {
    pthread_t ptid, ctid;
    pthread_create(&ptid, NULL, produce, NULL);
    pthread_create(&ctid, NULL, consume, NULL);
    pthread_join(ptid, NULL);
    pthread_join(ctid, NULL);
    return 0;
}

信号量

注意此地方是posix信号量,用于线程同步。(SYSTEM V信号量用于进程同步)

sem_init(&m_sem, 0, num);
sem_destroy(&m_sem);
sem_wait(&m_sem);//得到资源信号量减一或一直等待
sem_post(&m_sem);//信号量加1

读写锁

pthread_rwlock_init(&rwlock, NULL);
pthread_rwlock_destroy(&rwlock);
pthread_rwlock_rdlock(&rwlock);
pthread_rwlock_wrlock(&rwlock);
pthread_rwlock_unlock(&rwlock);

自旋锁

(忙等而不是阻塞等,用户层不常用)

pthread_spin_init(&m_spin, NULL);
pthread_spin_destroy(&m_spin);
pthread_spin_lock(&m_spin);
pthread_spin_unlock(&m_spin);
pthread_spin_trylock(&m_spin);
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,743评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,296评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,285评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,485评论 1 283
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,581评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,821评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,960评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,719评论 0 266
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,186评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,516评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,650评论 1 340
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,329评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,936评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,757评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,991评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,370评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,527评论 2 349