文档章节

Linux多线程——使用信号量同步线程

 猫改不了吃鱼
发布于 2017/05/15 15:18
字数 1069
阅读 7
收藏 0

 

一、什么是信号量

线程的信号量与进程间通信中使用的信号量的概念是一样,它是一种特殊的变量,它可以被增加或减少,但对其的关键访问被保证是原子操作。如果一个程序中有多个线程试图改变一个信号量的值,系统将保证所有的操作都将依次进行。

 

而只有0和1两种取值的信号量叫做二进制信号量,在这里将重点介绍。而信号量一般常用于保护一段代码,使其每次只被一个执行线程运行。我们可以使用二进制信号量来完成这个工作。

 

二、信号量的接口和使用

 

信号量的函数都以sem_开头,线程中使用的基本信号量函数有4个,它们都声明在头文件semaphore.h中。

 

1、sem_init函数

该函数用于创建信号量,其原型如下:

  1. int sem_init(sem_t *sem, int pshared, unsigned int value);  

该函数初始化由sem指向的信号对象,设置它的共享选项,并给它一个初始的整数值。pshared控制信号量的类型,如果其值为0,就表示这个信号量是当前进程的局部信号量,否则信号量就可以在多个进程之间共享,value为sem的初始值。调用成功时返回0,失败返回-1.

 

2、sem_wait函数

该函数用于以原子操作的方式将信号量的值减1。原子操作就是,如果两个线程企图同时给一个信号量加1或减1,它们之间不会互相干扰。它的原型如下:

  1. int sem_wait(sem_t *sem);  

sem指向的对象是由sem_init调用初始化的信号量。调用成功时返回0,失败返回-1.

 

3、sem_post函数

该函数用于以原子操作的方式将信号量的值加1。它的原型如下:

  1. int sem_post(sem_t *sem);  

与sem_wait一样,sem指向的对象是由sem_init调用初始化的信号量。调用成功时返回0,失败返回-1.

 

4、sem_destroy函数

该函数用于对用完的信号量的清理。它的原型如下:

 

  1. int sem_destroy(sem_t *sem);  

成功时返回0,失败时返回-1.

 

三、使用信号量同步线程

 

下面以一个简单的多线程程序来说明如何使用信号量进行线程同步。在主线程中,我们创建子线程,并把数组msg作为参数传递给子线程,然后主线程等待直到有文本输入,然后调用sem_post来增加信号量的值,这样就会立刻使子线程从sem_wait的等待中返回并开始执行。线程函数在把字符串的小写字母变成大写并统计输入的字符数量之后,它再次调用sem_wait并再次被阻塞,直到主线程再次调用sem_post增加信号量的值。

  1. #include <unistd.h>  
  2. #include <pthread.h>  
  3. #include <semaphore.h>  
  4. #include <stdlib.h>  
  5. #include <stdio.h>  
  6. #include <string.h>  
  7.   
  8. //线程函数  
  9. void *thread_func(void *msg);  
  10. sem_t sem;//信号量  
  11.   
  12. #define MSG_SIZE 512  
  13.   
  14. int main()  
  15. {  
  16.     int res = -1;  
  17.     pthread_t thread;  
  18.     void *thread_result = NULL;  
  19.     char msg[MSG_SIZE];  
  20.     //初始化信号量,其初值为0  
  21.     res = sem_init(&sem, 0, 0);  
  22.     if(res == -1)  
  23.     {  
  24.         perror("semaphore intitialization failed\n");  
  25.         exit(EXIT_FAILURE);  
  26.     }  
  27.     //创建线程,并把msg作为线程函数的参数  
  28.     res = pthread_create(&thread, NULL, thread_func, msg);  
  29.     if(res != 0)  
  30.     {  
  31.         perror("pthread_create failed\n");  
  32.         exit(EXIT_FAILURE);  
  33.     }  
  34.     //输入信息,以输入end结束,由于fgets会把回车(\n)也读入,所以判断时就变成了“end\n”  
  35.     printf("Input some text. Enter 'end'to finish...\n");  
  36.     while(strcmp("end\n", msg) != 0)  
  37.     {  
  38.         fgets(msg, MSG_SIZE, stdin);  
  39.         //把信号量加1  
  40.         sem_post(&sem);  
  41.     }  
  42.   
  43.     printf("Waiting for thread to finish...\n");  
  44.     //等待子线程结束  
  45.     res = pthread_join(thread, &thread_result);  
  46.     if(res != 0)  
  47.     {  
  48.         perror("pthread_join failed\n");  
  49.         exit(EXIT_FAILURE);  
  50.     }  
  51.     printf("Thread joined\n");  
  52.     //清理信号量  
  53.     sem_destroy(&sem);  
  54.     exit(EXIT_SUCCESS);  
  55. }  
  56.   
  57. void* thread_func(void *msg)  
  58. {  
  59.     //把信号量减1  
  60.     sem_wait(&sem);  
  61.     char *ptr = msg;  
  62.     while(strcmp("end\n", msg) != 0)  
  63.     {  
  64.         int i = 0;  
  65.         //把小写字母变成大写  
  66.         for(; ptr[i] != '\0'; ++i)  
  67.         {  
  68.             if(ptr[i] >= 'a' && ptr[i] <= 'z')  
  69.             {  
  70.                 ptr[i] -= 'a' - 'A';  
  71.             }  
  72.         }  
  73.         printf("You input %d characters\n", i-1);  
  74.         printf("To Uppercase: %s\n", ptr);  
  75.         //把信号量减1  
  76.         sem_wait(&sem);  
  77.     }  
  78.     //退出线程  
  79.     pthread_exit(NULL);  
  80. }  

源码地址获取mingli.com

有兴趣的朋友们可以前往球球哦~一起分享学习技术:2042849237

© 著作权归作者所有

粉丝 2
博文 40
码字总数 51358
作品 0
惠州
私信 提问
秒杀多线程第九篇 经典线程同步总结 关键段 事件 互斥量 信号量

前面《秒杀多线程第四篇一个经典的多线程同步问题》提出了一个经典的多线程同步互斥问题,这个问题包括了主线程与子线程的同步,子线程间的互斥,是一道非常经典的多线程同步互斥问题范例,后...

长平狐
2012/12/10
57
0
0-linux 环境编程修炼指南——外功心法

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/q1007729991/article/details/52770103 学习交流群: Linux 环境编程 610441700 说明:本系列文章并不能取代 ...

--Allen--
2016/10/09
0
0
秒杀多线程第九篇 经典线程同步总结 关键段 事件 互斥量 信号量

前面《秒杀多线程第四篇一个经典的多线程同步问题》提出了一个经典的多线程同步互斥问题,这个问题包括了主线程与子线程的同步,子线程间的互斥,是一道非常经典的多线程同步互斥问题范例,后...

晨曦之光
2012/05/21
91
0
pthread多线程(C语言) + Socket

pthread多线程(C语言) + Socket pthread是使用使用C语言编写的多线程的API, 简称Pthreads ,是线程的POSIX标准,可以在Unix / Linux / Windows 等系统跨平台使用。在类Unix操作系统(Unix、...

风清水遥
01/31
0
0
PV操作

哪里用pv操作   说起pv操作就要提到信号量,提到信号量就必须提到并发编程,并发是一种在时间上将多个逻辑控制流进行重叠的机制,也是现代计算机系统最显著和重要的特性。   在基于多线程...

dfhgshgdf
2017/11/05
0
0

没有更多内容

加载失败,请刷新页面

加载更多

任正非对华为热点问题的回应亮了,终于知道华为为什么能扛过这一次的冲击!

任正非对华为热点问题的回应亮了,终于知道华为为什么能扛过这一次的冲击! 如果你是华为的老板,看到一条传遍网络的“美国封锁华为”、“华为禁令”的消息,你会怎么办? 昨天上午,华为创始...

forespider
37分钟前
1
0
Java HTTP 组件库选型看这篇就够了

最近项目需要使用 Java 重度调用 HTTP API 接口,于是想着封装一个团队公用的 HTTP client lib. 这个库需要支持以下特性: 连接池管理,包括连接创建和超时、空闲连接数控制、每个 host 的连...

Java面经
38分钟前
2
0
nginx 重启

在 nginx.config 配置目录下 输入命令: nginx -s reload 在 nginx 中,如果我修改了一个配置文件,或者新增了一个配置文件。按照群里网友的描述,我需要关闭 nginx,或者重启 nginx,比较麻...

MrBoyce
39分钟前
0
0
Cesium中级5 - Terrain 地形

Cesium中文网:http://cesiumcn.org/ | 国内快速访问:http://cesium.coinidea.com/ CesiumJS支持对与水流相关的海洋、湖泊和河流以及全球高分辨率地形进行流式处理和可视化。查看山峰、山谷...

Cesium中文网
51分钟前
0
0
搭建jupyter+nginx服务

Tips:该文章面向Mac和centos用户,如果是Windows用户,请先安装虚拟机。 概述 Jupyter Notebook(此前被称为 IPython notebook)是一个交互式笔记本,支持运行 40 多种编程语言。 Jupyter ...

阿dai学长
52分钟前
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部