前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >Linux 信号量实现同步,实现互斥

Linux 信号量实现同步,实现互斥

作者头像
lexingsen
发布于 2022-02-25 00:35:07
发布于 2022-02-25 00:35:07
2.3K00
代码可运行
举报
文章被收录于专栏:乐行僧的博客乐行僧的博客
运行总次数:0
代码可运行

一.实现同步 同步模板

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
使用信号量实现同步时,需要将信号量的初值设置为0
semaphore s=0;
p1() {
	p(s);
	具体的代码
}

p2() {
	具体的代码
	v(s);
}

1.假设p1先执行,执行到p(s), s-=1, 此时s=-1<0,进程阻塞,主动放弃cpu使用权,cpu调度执行p2,执行p2的具体任务,然后进行v(s),,s+=1,s=0,p2执行完毕。cpu调度继续执行p1,此时s=0,p1被唤醒,因此就达到了先执行p2后执行p1的同步关系。 2.假设p2先执行,首先执行具体的代码,然后进行v(s),s+=1,s=1>0,然后p2执行完毕。cpu调度执行p1,p1首先p(s),s-=1,s=0,然后执行具体的代码。同样也达到了先执行p2后执行p1的同步关系。 二.Linux下信号量实现同步,线程2先执行输出"hello",线程1后执行输出"world\n"的功能

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
#include <iostream>
#include <pthread.h>
#include <semaphore.h>
#include <unistd.h>
#include <thread>
using namespace std;

int x = 10;

int main() {
  sem_init(&sem, 0, 0);
  thread t1([&](){
    cout << "hello";
    sem_post(&sem);
  });
  thread t2([&](){
    sem_wait(&sem);
    cout << "world" << endl;
  });
  t1.join();
  t2.join();
  sem_destroy(&sem);
  return 0;
}

执行结果:

三.实现互斥 互斥模板

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
互斥是对临界资源的保护  所以互斥只需要在临界区之前和之后分别进行加锁和解锁
需要注意的是,用信号量充当互斥锁实现互斥的时候,信号量的初值应设置为1,表示
临界资源的个数为1.

int x=10; 临界资源
semaphore s=1;

p1() {
	p(s);
	x ++; 访问临界资源
	v(s);
}

p2() {
	p(s);
	x --; 访问临界资源
	v(s);
}

1.假设p1先执行,p(s),s-=1,s=0,假设此时cpu时间片用完,cpu调度执行p2,p(s),s-=1,s=-1 < 0,此时p2阻塞,主动放弃cpu使用权,cpu调度执行p1,进行x++,v(s) s+=1, s=0,p1执行完毕。cpu调度执行p2,由于s=0,p2唤醒,执行x --, v(s),s+=1,s=1,p2执行完毕。此时信号量为1,表示可以临界资源个数为1。 2.假设p2先执行同上。 四.使用Linux信号量实现互斥

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
#include <iostream>
#include <pthread.h>
#include <semaphore.h>
#include <unistd.h>
#include <thread>
using namespace std;

int main() {
  sem_init(&sem, 0, 1);
  thread t1([&](){
    sem_wait(&sem);
    x ++;
    cout << "x = " << x << " this thread id:" << this_thread::get_id() << endl;
    sem_post(&sem);
  });

  thread t2([&](){
    sem_wait(&sem);
    x --;
    cout << "x = " << x << " this thread id:" << this_thread::get_id() << endl;
    sem_post(&sem);
  });

  t1.join();
  t2.join();
  sem_destroy(&sem);
}

执行结果:

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档