线程信号的传递

线程信号量

sem_inti;线程信号量初始化

#include <semaphore.h>
int sem_init(sem_t *sem, int pshared, unsigned int value);

参数：

sem_t *sem，定义的信号量
int pshared，为0，进程间共享；非0，线程间共享
unsigned int value：信号量的初始值

返回值：成功，返回0；失败，返回-1。

sem_wait;信号量的获取

#include <semaphore.h>
int sem_wait(sem_t *sem);

参数：

sem_t 线程号

返回值：成功，返回0；失败，返回-1；

sem_post

#include <semaphore.h>
int sem_post(sem_t *sem);

参数：

线程ID

返回值：成功，返回0；失败，返回-1；

sem_destory

 #include <semaphore.h>
int sem_destory(sem_t *sem);

参数：

线程ID

返回值：成功，返回0；失败，返回-1；

// 使用组合键Ctrl+c触发的SIGINT信号模拟产生资源的线程
#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>
#include <signal.h>
#include <unistd.h>
// 信号量：用于表示当前可用资源的数目，并对竞争线程进行同步
sem_t sem;

// 消费者线程函数
void *thread_func(void *arg);

// 信号处理函数
void sig_handler(int signo);

int main(int argc, char *argv[])
{
    pthread_t thread_id;

    // 注册SIGINT信号的处理函数
    signal(SIGINT, sig_handler);

    // 初始化信号量为0
    sem_init(&sem, 0, 0);
    
    pthread_create(&thread_id, NULL, thread_func, NULL);
    
    pthread_join(thread_id, NULL);
    
    printf("main thread exit...\n");
    
    // 销毁信号量
    sem_destroy(&sem);

    return 0;
}

void *thread_func(void *arg)
{
    while(1)
    {
        // sem -1zzzzzzzz
        // 对信号量进行wait(即-1)操作，如果<0，阻塞
        sem_wait(&sem);
    
        printf("thread 1...\n");
        
        sleep(3);
    }
}

void sig_handler(int signo)
{
    if(signo == SIGINT)
        // sem +1
        // 对信号量进行post(即+1)操作，如果<=0，系统唤醒一个等待线程
        sem_post(&sem);
}