linux环形buff模拟多线程信号量操作

互斥锁mutex变量的值非0即1,只能用来表示两种状态下的临界资源。而信号量是与之类似的,用来表示可用资源的,区别在于,信号量可以表示多个可用资源的。

--值为2的信号量也就是特殊的互斥锁了。

那么下边就简单实现信号量表示多个资源访问的生产者消费者问题了。

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

#include <semaphore.h>
#include <pthread.h>
#define _SIZE_ 128

int buf[_SIZE_];
sem_t blanks;
sem_t datas;

//生产者
void *producter(void *val)
{
    int beg = 0;
    while(1)
    {
        sem_wait(&blanks);
        int data = rand()%1024;
        buf[beg] = data;

        printf("%s done... data = %d\n",__func__,data);
        sem_post(&datas);
        beg = (beg+1)%_SIZE_;
        sleep(3);
    }
    return NULL;
}

//消费者
void *consumer(void *val)
{
    int start = 0;
    while(1)
    {
        sem_wait(&datas);
        int data = buf[start];

        printf("%s dene... data = %d\n", __func__,data);
        sem_post(&blanks);
        start = (start+1)%_SIZE_;
        sleep(5);
    }
    return NULL;
}

int main(int argc, char const *argv[])
{
    sem_init(&blanks,0,_SIZE_);
    sem_init(&datas,0,0);

    pthread_t id1,id2;
    pthread_create(&id1,NULL,producter,NULL);
    pthread_create(&id2,NULL,consumer,NULL);

    pthread_join(id1,NULL);
    pthread_join(id2,NULL);

    sem_destroy(&blanks);
    sem_destroy(&datas);
    return 0;
}

关于互斥锁,同步等问题,参加上篇博客

linux多线程-互斥&条件变量与同步

时间: 2024-08-06 20:05:58

linux环形buff模拟多线程信号量操作的相关文章

信号量实现环形buff下多生产者多消费者模型

posix下定义了一个semaphore,他和systemV版本下的sem很像,而这个多用于线程,它的单位是信号量,而sem的单位是信号量集.  #include <semaphore.h>  int sem_init(sem_t *sem, int pshared, unsigned int value);  int sem_destroy(sem_t *sem);  int sem_wait(sem_t *sem);  int sem_trywait(sem_t *sem);  int s

Linux下模拟多线程的并发并发shell脚本

分享一个在Linux下模拟多线程的并发脚本,使用这个脚本可以同时批量在定义数量的服务器上执行相关命令,比起普通for/while循环只能顺序一条一条执行的效率高非常多,在管理大批服务器时非常的实用.     以下脚本功能是通过scp(也可选rsync)向上千台服务器传更新包,脚本运行后同时在后台有50个scp进程向服务器传包.#!/bin/baship=`cat iplist.txt|grep -v "#"|awk '{print $1}'`   #过滤服务器IPdir='/usr/l

Linux高性能服务器编程——多线程编程(上)

多线程编程 Linux线程概述 线程模型 线程是程序中完成一个独立任务的完整执行序列,即一个可调度的实体.根据运行环境和调度者的身份,线程可分为内核线程和用户线程.内核线程,在有的系统上也称为LWP(Light Weigth Process,轻量级进程),运行在内核空间,由内核来调度:用户线程运行在用户空间,由线程库来调度.当进程的一个内核线程获得CPU的使用权时,它就加载并运行一个用户线程.可见,内核线程相当于用于线程运行的容器.一个进程可以拥有M个内核线程和N个用户线程,其中M≤N.并且在一

Linux下C语言多线程,网络通信简单聊天程序

原文:Linux下C语言多线程,网络通信简单聊天程序 功能描述:程序应用多线程技术,可是实现1对N进行网络通信聊天.但至今没想出合适的退出机制,除了用Ctr+C.出于演示目的,这里采用UNIX域协议(文件系统套接字),程序分为客户端和服务端.应用select函数来实现异步的读写操作. 先说一下服务端:首先先创建套接字,然后绑定,接下进入一个无限循环,用accept函数,接受“连接”请求,然后调用创建线程函数,创造新的线程,进入下一个循环.这样每当有一个新的“连接”被接受都会创建一个新的线程,实现

Linux高性能服务器编程——多线程编程(下)

多线程编程 条件变量 如果说互斥锁是用于同步线程对共享数据的访问的话,那么条件变量则是用于线程之间同步共享数据的值.条件变量提供了一种线程间的通信机制:当某个共享数据达到某个值得时候,唤醒等待这个共享数据的线程. 条件本身是由互斥量保护的.线程在改变条件状态前必须首先锁住互斥量,其他现成在获得互斥量之前不会察觉到这种变化,因为必须锁住互斥量以后才能计算条件. 条件变量的相关函数主要有如下5个: #include <pthread.h> int pthread_cond_destroy(pthr

C#多线程--信号量(Semaphore)

百度百科:Semaphore,是负责协调各个线程, 以保证它们能够正确.合理的使用公共资源.也是操作系统中用于控制进程同步互斥的量. Semaphore常用的方法有两个WaitOne()和Release(),Release()的作用是退出信号量并返回前一个计数,而WaitOne()则是阻止当前线程,直到当前线程的WaitHandle 收到信号.这里我举一个例子让大家更容易理解:当我们这样实例化Semaphore时候 Semaphore sema = new Semaphore( x , y );

Linux程序设计学习笔记----多线程编程线程同步机制之互斥量(锁)与读写锁

互斥锁通信机制 基本原理 互斥锁以排他方式防止共享数据被并发访问,互斥锁是一个二元变量,状态为开(0)和关(1),将某个共享资源与某个互斥锁逻辑上绑定之后,对该资源的访问操作如下: (1)在访问该资源之前需要首先申请互斥锁,如果锁处于开状态,则申请得到锁并立即上锁(关),防止其他进程访问资源,如果锁处于关,则默认阻塞等待. (2)只有锁定该互斥锁的进程才能释放该互斥锁. 互斥量类型声明为pthread_mutex_t数据类型,在<bits/pthreadtypes.h>中有具体的定义. 互斥量

打造百度网盘备份利器:自动备份Linux VPS文件和多线程下载百度网盘资源

前一段时间国内的各大网盘百度云盘,金山快盘,360云盘,华为网盘为争夺用户上演空间容量博弈,网盘商们还固执地以为中国的网民都不懂网络技术,可以像某公司那样用一些数字的手段来忽悠用户,参与到网盘商的数字游戏中的公司都心知肚明. 在不需要增加任何网盘上传下载带宽和硬件设备投入的情况下,又可以用TB级别网盘这样的字眼来夺人眼球,在网络上大肆炒作一番,这比用钱买广告来推广网盘有效得多了.在这场网盘炒作中,率先“挑起事非”的两家百度网盘和360网盘获利最多. 尤其是百度网盘,应该算正式成长为国内网盘界中老

TECPLOT.CHORUS.2015.R2.WIN.LINUX.X64 CFD模拟分析

TECPLOT.CHORUS.2015.R2.WIN.LINUX.X64 CFD模拟分析Tecplot  Chorus为工程师分析大量模拟数据提供了一个崭新的工具.Tecplot Chorus集成了元数据分析.后处理和模拟数据管理功能,方便 于加快工程决策的制定.在CFD研究中,Tecplot Chorus使工程师能更加简单地发现趋势和异常情况,同时洞察引起这些变化的潜在的流动现象.通过帮助工程师协作分析大量模拟数据,Tecplot Chorus将会有助于工程师更快地获得更加有信息的结果. Si