免费快递网站源码企业培训课程体系

信号量

(1)What（什么是信号量）

提供一种计数器的方式控制对共享资源的访问；当计数器大于0时，请求资源成功并计数器-1；当计数器小于0时，线程阻塞，等待其它线程执行signal（V操作）唤醒它

(2)Why（信号量的作用）

• 实现线程的同步与互斥：通过信号量的设计，可以实现对共享资源的串行访问
• 实现线程的等待与通知机制：当信号量小于0时，当前线程将被阻塞；当信号量大于0时，会唤醒一个阻塞在信号量上的线程

(3)How（如何使用信号量实现线程同步）

step01：创建信号量

可以看作是创建一个信号量对象

sem_t sem; 

step02：初始化信号量

可以看作是对信号量对象的一个初始化，这一过程会给信号量的计数器赋予一个初始值

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

• 参数sem：被初始化的信号量对象
• 参数pshared：默认为0，表示信号量用于线程同步；其它表示信号量用于进程同步
• 参数value：表示信号量的数量，常用用于表示共享资源的数量
• 返回值：成功返回0，失败返回－1，并设置错误码

step03：请求资源

请求获取共享资源，此时信号量的计数器减1；如果信号量小于1，请求失败，线程阻塞，直到信号量满足条件时解除阻塞

int sem_wait(sem_t *sem); 

• 参数sem：请求共享资源，如果sem中的计数器大于0，则请求成功，否则线程阻塞
• 返回值：成功返回0，失败返回－1，并设置错误码

step04：释放资源

释放共享资源，此时信号量的计数器加1，此时会唤醒一个等待该共享资源的线程

int sem_post(sem_t *sem);

• 参数sem：释放共享资源，sem中的计数器＋1
• 返回值：成功返回0，失败返回－1，并设置错误码
  step05：销毁信号量

本质就是释放信号量对象的内存空间

int sem_destroy(sem_t *sem); 

• 参数sem：将要被销毁的信号量对象
• 返回值：成功返回0，失败返回－1，并设置错误码

(4）代码实例

以下代码是对共享资源的互斥访问，共享资源的个数为5

#include <semaphore.h>
#include <unistd.h>
#include <iostream>
#include <pthread.h>
using namespace std;
pthread_mutex_t mutex;
sem_t semProc;
sem_t semComu;
struct Node{int iVal;Node * ptrNext;static int iSize;
};
int Node::iSize = 0;
Node * head = NULL;
void *produce(void  *arg){int i = 0;while(1){sem_wait(&semProc);pthread_mutex_lock(&mutex);int iVal = i;Node *node = new Node;node->iVal = iVal;node->ptrNext = head->ptrNext;head->ptrNext = node;Node::iSize++;cout<<"Producing "<<iVal<<"("<<Node::iSize<<")"<<endl;pthread_mutex_unlock(&mutex);sem_post(&semComu);++i;sleep(1);}
}
void *consume(void *arg){while(1){sem_wait(&semComu);pthread_mutex_lock(&mutex);if(head->ptrNext!=NULL){cout<<"Comsuing "<<head->ptrNext->iVal;Node *ptr = head->ptrNext;head->ptrNext = ptr->ptrNext;Node::iSize--;delete ptr;cout<<"("<<Node::iSize<<")"<<endl;ptr = 0;}pthread_mutex_unlock(&mutex);sem_post(&semProc);sleep(2);｝return NULL; 
}
int main()
{head = new Node; pthread_t tidProc,  tidComu; sem_init(&semProc, 0, 5); sem_init(&semComu, 0, 0); pthread_create(&tidProc,  NULL,  produce,  NULL); pthread_create(&tidComu, NULL, conmuse, NULL); pthread_join(tidProc, NULL); pthread_join(tidComu, NULL); return 0; 
}