Linux c==信号量实现线程之间的PV操作(16)

时间:2022-05-27 15:17:43

1.信号量实现线程之间的PV操作,实现线程同步和互斥的数据模型?
(1).sem_init函数
函数作用:初始化信号量
函数原型:int sem_init(sem_t *sem,int pshared, unsigned int value)
参数:sem:信号量指针
Pshared:决定信号量能否在几个进程间共享,一般取0
Value:信号量的初始值
(2).信号的操作

intsem_wait(sem_t *sem);    P操作   
intsem_try_wait(sem_t *sem);
intsempost(sem_t *sem); V操作
intsem_getvalue(sem_t *sem);
intsem_destroy(sem_t *sem); 销毁信号
[objc] view plain copy print?在CODE上查看代码片派生到我的代码片
#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>

sem_t sem1;
sem_t sem2;
//PV操作:实现同步,先实现func1,后实现func2

voidvoid *myThread1(void)
{
int i;

sem_wait(&sem1);
for(i = 0; i < 5; i++)
{
printf("Hello\n");
sleep(1);
}
sem_post(&sem2);
}

voidvoid *myThread2(void)
{
int i;

sem_wait(&sem2);
for(i = 0; i < 5; i++)
{
printf("world!\n");
sleep(1);
}
sem_post(&sem1);
}

int main()
{
int ret = 0;
pthread_t id1;
pthread_t id2;

sem_init(&sem1, 0, 1);
sem_init(&sem2, 0, 0);

ret = pthread_create(&id1, NULL, (voidvoid *)myThread1, NULL);

if(ret)
{
printf("Create pthread error\n");
return 1;
}

ret = pthread_create(&id2, NULL, (voidvoid *)myThread2, NULL);

if(ret)
{
printf("Create pthread error\n");
return 1;
}

pthread_join(id1, NULL);
pthread_join(id2, NULL);

sem_destroy(&sem1);
sem_destroy(&sem2);

return 0;

}