一個簡單的信號量的例子


1. 信號量

Linux提供了控制線程執行和訪問代碼臨界區域的方法。其中最基本的兩種辦法是信號量和互斥量。

關於互斥量,筆者在Linux互斥量中介紹

本文只介紹semaphore.h 相關的信號量的簡單的操作。關於信號量在筆者其他博客里有詳細介紹。

Linux還有其他共享內存的方法。

2. 信號量相關函數

 

 


# include <semaphore.h >

int sem_init(sem_t *sem, int pshared, unsigned int value); //創建信號量

int sem_post(sem_t *sem); // +1操作

int sem_wait(sem_t *sem); //  -1操作

int sem_destroy(sem_t *sem); //銷毀

 

 

3. 程序代碼:

/***************************************
 *    @file            semaphore.c
 *    @brief        線程信號量
 *    @author        Windeal
 *    @date        2013/08/06
***************************************/

 
# include <stdlib.h >
# include <stdio.h >
# include <unistd.h >
# include <string.h >
# include <pthread.h >
# include <semaphore.h >
 
# define WORK_SIZE 1024     //
 
char work_area[WORK_SIZE];
sem_t bin_sem;
 
void *thread_function( void * arg);
 
int main( int argc, char * argv [ ])
{
     int ret ;
     void * thread_result;
    pthread_t a_thread;
 
    ret = sem_init( &bin_sem, 0, 0);      //初始化信號量為0
     if (ret != 0) {
        perror( "sem_init()  is failed!\n");
        exit(EXIT_FAILURE);
    }
 
    ret = pthread_create( &a_thread, NULL, thread_function, NULL);
     if (ret != 0) {
        perror( "thread create failed!\n");
        exit(EXIT_FAILURE);
    }
 
    printf( "Enter 'end' to finish!\n");
     while (strncmp( "end", work_area, 3) != 0) {
        fgets(work_area, WORK_SIZE, stdin);
        sem_post( &bin_sem);            // 信號量+ 1 操作
    }
 
    printf( "Waitint for thread join\n");
    ret = pthread_join(a_thread, &thread_result);
     if (ret != 0) {
        perror( "thread_join  failed!\n");
        exit(EXIT_FAILURE);
    }
 
    printf( "thread join()\n");
    sem_destroy( &bin_sem);
    exit(EXIT_FAILURE);
 
}
 
void *thread_function( void * arg){
    sem_wait( &bin_sem);                   // 信號量- 1 操作
     while (strncmp( "end", work_area, 3) != 0){
        printf( "you input %d charactor \n", strlen(work_area) - 1);
        sem_wait( &bin_sem);                   // 信號量- 1 操作
    }
    pthread_exit(NULL);
}
 

 

運行結果:

 


注意!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系我们删除。



 
粤ICP备14056181号  © 2014-2020 ITdaan.com