技术标签: linux线程信号量 函数
#include
#include /* For O_CREAT constants */
#include /* For sem_ constants */
#include /* For pthread_create constants */
void pthreadRun(void *arg);
void pthreadStop(void *arg);
sem_t* semStop;
sem_t* semRun;
int main()
{
pthread_t pID1, pID2;
int nRetP1, nRetP2;
printf("\n\n");
// 创建信号量
semStop = sem_open("semStop", /*O_RDWR |*/ O_CREAT, 0644, 0); //
semRun = sem_open("semRun,", /*O_RDWR |*/ O_CREAT, 0644,0); //
if(SEM_FAILED == semStop || SEM_FAILED == semRun)
{
printf("Opened error\n");
return 1;
}
// 初始化信号量
sem_init(semStop, 0, 0);
// int sem_init(sem_t *sem, int pshared, unsigned int value);
// If pshared has the value 0, then the semaphore is shared between the threads of a process
// The value argument specifies the initial value for the semaphore.
sem_init(semRun, 0, 0);
// 创建 信号量同步的 线程
printf("now create two threads for synchronization. \n");
nRetP2 = pthread_create(&pID2, NULL, (void*) pthreadStop, NULL);
usleep(2*1000);
nRetP1 = pthread_create(&pID1, NULL, (void*) pthreadRun, NULL);
if(nRetP1 != 0) {
printf("nRetP1 pthread_create failed! \n");
return 2;
}
if(nRetP2 != 0) {
printf("nRetP2 pthread_create failed! \n");
return 2;
}
// 关闭信号量
sem_close(semStop);
sem_close(semRun);
// 暂停 60 秒, 观看两线程同步
usleep(60*1000);
printf("\n\n");
return 0;
}
void pthreadRun(void *arg)
{
while(1)
{
// 等待开车
printf("wait for semRun\n");
sem_wait(semRun);
// 正常行车
printf("runing\n");
// 停车
printf("post semStop\n");
sem_post(semStop);
}
}
void pthreadStop(void *arg)
{
while(1)
{
// 上乘客
printf("get on the bus.\n");
// 关车门,通知司机开车
printf("post semRun.\n");
sem_post(semRun);
// 卖车票
printf("Selling tickets.\n");
// 等待停车
printf("wait for semStop\n");
sem_wait(semStop);
// 下乘客
printf("get off\n");
}
}
/* 编译:(gcc 编译选项需要加入一个多线程选项: -pthread)
hangken@ubuntu:~$ gcc -o bus/bus -g bus/bus.c -pthread
*/
/* 运行结果:
hangken@ubuntu:~$ sudo ./bus/bus
now create two threads for synchronization.
get on the bus.
post semRun.
Selling tickets.
wait for semStop
wait for semRun
runing
post semStop
Segmentation fault
hangken@ubuntu:~$
*/
/* 主要用到的信号量函数有:
sem_init:初始化信号量sem_t,初始化的时候可以指定信号量的初始值,以及是否可以在多进程间共享。
sem_wait:一直阻塞等待直到信号量>0。
sem_timedwait:阻塞等待若干时间直到信号量>0。 //等待信号量变成>0,
// int sem_wait_i( sem_t *psem, int mswait ) mswait为等待时间,若mswait<0则无穷等待,否则等待若干mswait毫秒
sem_post:使信号量加1。
sem_destroy:释放信号量。和sem_init对应。
关于各函数的具体参数请用man查看。如man sem_init可查看该函数的帮助。
*/
文章浏览阅读347次。idea shift f6 快捷键无效_idea shift +f6快捷键不生效
文章浏览阅读135次。Ecmacript 中没有DOM 和 BOM核心模块Node为JavaScript提供了很多服务器级别,这些API绝大多数都被包装到了一个具名和核心模块中了,例如文件操作的 fs 核心模块 ,http服务构建的http 模块 path 路径操作模块 os 操作系统信息模块// 用来获取机器信息的var os = require('os')// 用来操作路径的var path = require('path')// 获取当前机器的 CPU 信息console.log(os.cpus._node模块中有很多核心模块,以下不属于核心模块,使用时需下载的是
文章浏览阅读10w+次,点赞435次,收藏3.4k次。SPSS 22 下载安装过程7.6 方差分析与回归分析的SPSS实现7.6.1 SPSS软件概述1 SPSS版本与安装2 SPSS界面3 SPSS特点4 SPSS数据7.6.2 SPSS与方差分析1 单因素方差分析2 双因素方差分析7.6.3 SPSS与回归分析SPSS回归分析过程牙膏价格问题的回归分析_化工数学模型数据回归软件
文章浏览阅读7.5k次。如何利用hutool工具包实现邮件发送功能呢?1、首先引入hutool依赖<dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.7.19</version></dependency>2、编写邮件发送工具类package com.pc.c..._hutool发送邮件
文章浏览阅读867次,点赞2次,收藏2次。docker安装elasticsearch,elasticsearch-head,kibana,ik分词器安装方式基本有两种,一种是pull的方式,一种是Dockerfile的方式,由于pull的方式pull下来后还需配置许多东西且不便于复用,个人比较喜欢使用Dockerfile的方式所有docker支持的镜像基本都在https://hub.docker.com/docker的官网上能找到合..._docker安装kibana连接elasticsearch并且elasticsearch有密码
文章浏览阅读370次。算法分析的概念程序和算法的区别算法是对问题解决的分步描述。程序是采用某种编程语言实现的算法算法分析主要就是从计算资源消耗的角度来评判和比较算法更高效利用计算资源,或者更少占用计算资源的算法就是好算法。计算资源指标一种是算法解决问题过程中需要的存储空间或内存存储空间收到问题自身数据规模的变化影响要区分哪些存储空间是问题本身描述所需,哪些是算法占用不容易另一种是算法的执行时间可以对程序进行实际运行测试,获得真实的运行时间运行时间检测Python中有一个time模块,可以获取计算机系统当前_所谓“变位词”是指两个词之间存在组成字母的重新排列关系。如:heart和earth,pyth
文章浏览阅读7.9k次。//// ViewController.swift// Day_10_Timer//// Created by dongqiangfei on 2018/10/15.// Copyright 2018年 飞飞. All rights reserved.//import UIKitclass ViewController: UIViewController { ..._swift timer 暂停
文章浏览阅读986次,点赞2次,收藏2次。1.硬性等待让当前线程暂停执行,应用场景:代码执行速度太快了,但是UI元素没有立马加载出来,造成两者不同步,这时候就可以让代码等待一下,再去执行找元素的动作线程休眠,强制等待 Thread.sleep(long mills)package com.example.demo;import org.junit.jupiter.api.Test;import org.openqa.selenium.By;import org.openqa.selenium.firefox.Firefox.._元素三大等待
文章浏览阅读3k次,点赞4次,收藏14次。Java软件工程师职位分析_java岗位分析
文章浏览阅读2k次。Java:Unreachable code的解决方法_java unreachable code
文章浏览阅读1w次。1、html中设置标签data-*的值 标题 11111 222222、点击获取当前标签的data-url的值$('dd').on('click', function() { var urlVal = $(this).data('ur_如何根据data-*属性获取对应的标签对象
文章浏览阅读6.9w次,点赞73次,收藏463次。1.前序创建#include<stdio.h>#include<string.h>#include<stdlib.h>#include<malloc.h>#include<iostream>#include<stack>#include<queue>using namespace std;typed_二叉树的建立