linux 信号量线程同步

通过使用信号量可以很好的完成线程同步。两个线程同时监视同一个信号量。A线程增加信号量的值，B

线程减少信号量的值。 当A线程增加信号量大于0时，B线程的等待信号量就会触发，每触发一次将信号量减1，直到将信号量减为0，B线程继续等待A线程增加信号量。

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

int sem_wait(sem_t * sem);

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<pthread.h>
#include<semaphore.h>
//线程执行函数
void *thread_func(void *arg);
//信号量
sem_t bin_sem;
#define WORK_SIZE 1024
char work_area[WORK_SIZE];
int main()
{
        int res;
        pthread_t athread;
        void *thread_result;
        //初始化信号量
        res = sem_init(&bin_sem,0,0);
        if(0 != res)
        {
                printf("sem init failture\n");
                exit(-1);
        }
        //创建子线程
        res = pthread_create(&athread,NULL,thread_func,NULL);
        if(0 != res)
        {
                printf("create thread failtrue\n");
                exit(-1);
        }
        printf("input some test , enter end to finish\n");
        while(strncmp("end",work_area,3) != 0)
        {
                scanf("%s",work_area);
                //增加信号量
                sem_post(&bin_sem);
        }
 printf("\nwaiting thread for finish.....\n");
//等待子线程结束
        res =
pthread_join(athread,&thread_result);
        if(0 != res)
        {
                printf("thread join failtrue \n");
                exit(-1);
        }
        printf("thread join\n");
        sem_destroy(&bin_sem);
        exit(0);
}
void * thread_func(void * arge)
{
        //减少信号量
        sem_wait(&bin_sem);
        while(strncmp("end",work_area,3) != 0)
        {
                printf("you input is %s\n",work_area);
                sem_wait(&bin_sem);
        }
        pthread_exit(NULL);
}

本文出自 “风清扬song” 博客，请务必保留此出处http://2309998.blog.51cto.com/2299998/1386920

linux 信号量线程同步,古老的榕树,5-wow.com