该例子,确实简要地说明了如何用信号量实现两个线程的同步。
#include <stdio.h>
#include <stdlib.h>
#include <semaphore.h>
#include <pthread.h>
sem_t smt;
void DisplayData()
{
printf ("Display a frame\n");
}
void *ThreadFuncDisplay(void *arg)
{
while (1){
printf ("sem_wait........\n");
sem_wait (&smt);
DisplayData();
}
}
void *ThreadFuncControl(void *arg)
{
while (1){
sleep (3);
sem_post (&smt);
printf ("sem_post\n");
}
}
int main(int argc, char *argv[])
{
gtk_init (&argc, &argv);
int rt;
pthread_t pt_dsp;
pthread_t pt_ctrl;
rt = sem_init (&smt, 0, 0);
if (rt){
perror ("semaphore initialization failed");
}
pthread_create (&pt_dsp, NULL, ThreadFuncDisplay, NULL);
pthread_create (&pt_ctrl, NULL, ThreadFuncControl, NULL);
gtk_main();
return 0;
}
|
其实,与同步相关的的就是三个函数:
1、sem_init (&smt, 0, 0) //创建semophore
2、sem_wait (&smt); //等待信号量
3、sem_post (&smt); //释放信号量
另外,上面的例子,因为main没有调用pthread_join(),不知道会不会出现线程创建完毕后就直接随着main的结束而直接退出。
阅读(1341) | 评论(0) | 转发(0) |