一个简单的信号量的例子

左手的ㄟ右手 2021-10-29 19:28 369阅读 0赞

1. 信号量

Linux提供了控制线程执行和访问代码临界区域的方法。其中最基本的两种办法是信号量和互斥量。

关于互斥量，笔者在[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);  
\}

运行结果：

![Image 1][]

![Center][]

[Linux]: http://blog.csdn.net/windeal/article/details/9962373
[Image 1]: 
[Center]: /images/20211029/10504b7cc9774444bb295b4f0dd7bba8.png