[C++][linux]C++实现类似C#AutoResetEvent或者win C++的SetEvent

Posted 2023-03-04 FL1623863129

在Linux上可以使用下面一组函数实现：

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 sem_post(sem_t *sem); 
int sem_getvalue(sem_t *sem); 
具体要Include什么头文件，在你的系统上man sem_init吧。
这组函数是POSIX标准的无名信号量函数，另外还有具名信号亮，这个嘛，等下回再说。
 
看一个例子，比如有两个线程都要往打印机上打东西，但是同一时刻只能打一个。
那么首先用sem_init初始化一个信号量，注意pshared表示允许几个进程共享该信号量，一般设0用于进程内的多线程共享，要看是否支持进程共享，请查看下你的系统的man手册。
第三个参数value表示可用的资源的数目，即信号灯的数目，咱们这儿只有1个打印机所以设成1。
然后线程调用sem_wait取获取这个信号灯，第一个线程一看，有1个，他就拿到了，然后可以继续后继操作，此时信号灯自动减1，变成0个。那么第二个线程调用sem_wait时就会阻塞在这儿了。
第一个线程完成打印后，调用sem_post释放信号灯，信号灯数目变成1，将会唤醒等待的第二个线程，然后第二个线程接着打印。
最后当所有任务完成后，主线程调用sem_destroy释放这个信号量。

sem_init
是Posix信号量操作中的函数，初始化一个定位在 sem 的匿名信号量。

//参数1，sem为指向信号量结构的一个指针
//参数2，pshared不为0时此信号量在进程间共享，否则只能为当前进程的所有线程共享；
//参数3，value给出了信号量的初始值。
//返回值，成功返回0，失败返回 -1，设置errno。
int sem_init (sem_t *sem, int pshared, unsigned int value); 
sem_wait
用来阻塞当前线程直到信号量sem的值大于0，解除阻塞后将sem的值减1
1、sem_wait函数是一个原子操作，它的作用是从信号量的值减去一个“1”
2、它永远会先等待该信号量为一个非零值才开始做减法。也就是说，如果对一个值为2的信号量调用sem_wait(),线程将会继续执行，信号量的值将减到1。
3、如果对一个值为0的信号量调用sem_wait()，这个函数就 会地等待直到有其它线程增加了这个值使它不再是0为止。
4、如果有两个线程都在sem_wait()中等待同一个信号量变成非零值，那么当它被第三个线程增加 一个“1”时，等待线程中只有一个能够对信号量做减法并继续执行，另一个还将处于等待状态。

//参数，由sem_init调用初始化的信号量对象的指针
//返回值，成功返回0,失败时信号量的值不改动,返回-1.errno标识错误.
int sem_wait(sem_t * sem);
sem_trywait
sem_trywait是sem_wait的非阻塞版本。函数 sem_trywait和sem_wait有一点不同，即如果信号量的当前值为0，则返回错误而不是阻塞调用。错误值errno设置为EAGAIN。

int sem_trywait(sem_t *sem);
sem_post
给信号量的值加上一个“1”
1、它是一个“原子操作”－－－即同时对同一个信号量做加“1”操作的两个线程是不会冲突的；
2、当有线程阻塞在这个信号量上时，调用这个函数会使其中一个线程不在阻塞，选择机制是由线程的调度策略决定的。

//返回值，成功返回 0；错误时，信号量的值没有更改，返回-1，并设置 errno 来指明错误。
int sem_post(sem_t *sem);
 

案列：

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>
 
  sem_t sem;
 
  void func1(void* arg)
  
      sem_wait(&sem);
      int *running=arg;
      printf("thread running1\\n");
      printf("%d\\n",*running);
  
 
  void func2(void* arg)
  
      printf("pthread2 running\\n");
      sem_post(&sem);
  
 
  int main()
  
      sem_init(&sem,0,0);
      pthread_t thread[2];
      int a=5;
      pthread_create(&(thread[0]),NULL,(void*)func1,(void*)&a);
      printf("main thread running\\n");
      sleep(10);
      pthread_create(&(thread[1]),NULL,(void*)func2,(void*)&a);
      printf("main thread running2\\n");
      pthread_join(thread[0],NULL);
      pthread_join(thread[1],NULL);
      sem_destroy(&sem);
 
      return 0;