Linux下多线程编程简介(四)

简介:
   除了上次讲的互斥锁,使用信号量也就是操作系统中所提到的PV原语,也能达到互斥和同步的效果,这就是下面要说的信号量线程控制。
 
         PV原语是对整数计数器信号量sem的操作,一次P操作可使sem减一,而一次V操作可是sem加一。进程(或线程)根据信号量的值来判断是否对公共资源具有访问权限。当信号量的值大于零或等于零的时候,该进程(或线程)具有对公共资源访问的权限,否则,当信号量的值小于时,该进程(或线程)就会被阻塞,直到信号量的值大于或等于一。
         
         在LINUX中,实现了POSIX的无名信号量,主要用于线程间的互斥同步,下面将简单介绍一些函数接口:
 
sem_init
功能:         用于创建一个信号量,并初始化信号量的值。
函数原型:     int sem_init (sem_t* sem, int pshared, unsigned int value);
 
int sem_wait       (sem_t* sem);
int sem_trywait   (sem_t* sem);
int sem_post       (sem_t* sem);
int sem_getvalue (sem_t* sem);
int sem_destroy   (sem_t* sem);
 
功能:
        sem_wait和sem_trywait相当于P操作,它们都能将信号量的值减一,两者的区别在 于若信号量的值小于零时,sem_wait将会阻塞进程,而sem_trywait则会立即返回。
        sem_post相当于V操作,它将信号量的值加一,同时发出唤醒的信号给等待的进程 (或线程)。
        sem_getvalue 得到信号量的值。
        sem_destroy 摧毁信号量。
 
程序实例如下:
 
#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <errno.h>
#include <semaphore.h>
 
#define return_if_fail(p) \
         if(!p) { printf("[%s]:func error!", __func__); return; }
 
typedef struct _PrivInfo {
         sem_t sem;
         int lock_var;
         time_t end_time;
}PrivInfo;
 
void  info_init(PrivInfo *thiz);
void *pthread_function1(void *paramthiz);
void *pthread_function2(void *paramthiz);

int main (int argc, char** argv) {
          pthread_t pt_1 = 0;
          pthread_t pt_2 = 0;
          int ret = 0;
         PrivInfo *thiz = NULL;
          thiz = (PrivInfo*)malloc(sizeof(PrivInfo));
          if(NULL == thiz) {
           return -1;
          }
          info_init(thiz);
          ret = pthread_create(&pt_1, NULL, pthread_function1, (void*)thiz);
          if(0 != ret) {
                   perror("pthread1 creation failed!"); 
         }
 
          ret = pthread_create(&pt_2, NULL, pthread_function2,(void*)thiz);
          if(0 != ret) {
                   perror("pthread2 creation failed!"); 
         }
          pthread_join(pt_1, NULL);
          pthread_join(pt_2, NULL);
          sem_destroy(&thiz->sem);
 
          free(thiz); 
         thiz = NULL;
 
         return 0;
}
 
void info_init(PrivInfo *thiz) {
          return_if_fail(&thiz != NULL);
          thiz->lock_var = 0;
         thiz->end_time = time(NULL) + 10;
         sem_init(&thiz->sem, 0, 1);
 
         return;
}
 
void *pthread_function1(void *paramthiz) { 
         int i = 0;
         PrivInfo *thiz = (PrivInfo *)paramthiz;
         while(time(NULL) < thiz->end_time) {
                  sem_wait(&thiz->sem);
                  printf("thread1 get the lock.\n");
  
                  for(; i<2; i++) {
                           thiz->lock_var ++;
                           sleep(3);
                  }
  
                  sem_post(&thiz->sem);
                  printf("thread1 unlock.\n");
         }
  
         sleep(1);
         pthread_exit(NULL);
}
 
void *pthread_function2(void *paramthiz) { 
         PrivInfo *thiz = (PrivInfo *)paramthiz;
         while(time(NULL) < thiz->end_time) {
                  sem_wait(&thiz->sem);
                  printf("thread2 get the lock. The lock_var = %d.\n",
                                 thiz->lock_var);
  
                  sem_post(&thiz->sem);
                  printf("thread2 unlock.\n");
 
                  sleep(3);
         }
  
         pthread_exit(NULL);
}
 

本文转自jazka 51CTO博客,原文链接:http://blog.51cto.com/jazka/234585,如需转载请自行联系原作者
相关文章
|
5月前
|
机器学习/深度学习 消息中间件 存储
【高薪程序员必看】万字长文拆解Java并发编程!(9-2):并发工具-线程池
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发编程中的强力并发工具-线程池,废话不多说让我们直接开始。
189 0
|
8月前
|
存储 Linux API
【Linux进程概念】—— 操作系统中的“生命体”,计算机里的“多线程”
在计算机系统的底层架构中,操作系统肩负着资源管理与任务调度的重任。当我们启动各类应用程序时,其背后复杂的运作机制便悄然展开。程序,作为静态的指令集合,如何在系统中实现动态执行?本文带你一探究竟!
【Linux进程概念】—— 操作系统中的“生命体”,计算机里的“多线程”
|
6月前
|
并行计算 Linux
Linux内核中的线程和进程实现详解
了解进程和线程如何工作,可以帮助我们更好地编写程序,充分利用多核CPU,实现并行计算,提高系统的响应速度和计算效能。记住,适当平衡进程和线程的使用,既要拥有独立空间的'兄弟',也需要在'家庭'中分享和并行的成员。对于这个世界,现在,你应该有一个全新的认识。
248 67
|
5月前
|
安全 算法 Ubuntu
Linux(openssl)环境:编程控制让证书自签的技巧。
总结:在Linux环境中,OpenSSL是一个非常实用的工具,可以帮助我们轻松地生成自签名证书。通过上述三个简单步骤,即可为内部网络、测试环境或开发环境创建自签名证书。但在公共访问场景下,建议购买经过权威认证机构签发的证书,以避免安全警告。
231 13
|
7月前
|
JavaScript Ubuntu Linux
如何在阿里云的linux上搭建Node.js编程环境?
本指南介绍如何在阿里云Linux服务器(Ubuntu/CentOS)上搭建Node.js环境,包含两种安装方式:包管理器快速安装和NVM多版本管理。同时覆盖全局npm工具配置、应用部署示例(如Express服务)、PM2持久化运行、阿里云安全组设置及外部访问验证等步骤,助你完成开发与生产环境的搭建。
|
8月前
|
Linux
Linux编程: 在业务线程中注册和处理Linux信号
通过本文,您可以了解如何在业务线程中注册和处理Linux信号。正确处理信号可以提高程序的健壮性和稳定性。希望这些内容能帮助您更好地理解和应用Linux信号处理机制。
132 26
|
8月前
|
Linux
Linux编程: 在业务线程中注册和处理Linux信号
本文详细介绍了如何在Linux中通过在业务线程中注册和处理信号。我们讨论了信号的基本概念,并通过完整的代码示例展示了在业务线程中注册和处理信号的方法。通过正确地使用信号处理机制,可以提高程序的健壮性和响应能力。希望本文能帮助您更好地理解和应用Linux信号处理,提高开发效率和代码质量。
136 17
|
10月前
|
安全 Java API
【JavaEE】多线程编程引入——认识Thread类
Thread类,Thread中的run方法,在编程中怎么调度多线程
|
消息中间件 存储 缓存
【嵌入式软件工程师面经】Linux系统编程(线程进程)
【嵌入式软件工程师面经】Linux系统编程(线程进程)
266 1
|
Linux 调度 数据库
Linux下的系统编程——线程同步(十三)
Linux下的系统编程——线程同步(十三)
216 0
Linux下的系统编程——线程同步(十三)