Linux下多线程编程简介（六）

作者佚名技术来源 Linux系统浏览发布时间 2012-04-28

本篇将根据前面所学的知识,设计一个简单的生产者/消费者模式. 有一个缓冲区和两个线程：生产者和消费者.生产者把产品放入缓冲区,而消费者从缓冲区中拿走.当缓冲区满时,生产者

等待；另外,当缓冲区空时,消费者

等待,并且缓冲区不能同时进行生产者和消费者的操作. #include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <errno.h>
#include <semaphore.h> #define return_if_fail(p)
if(!p) { printf("[%s]:func error!", __func__); return; } typedef struct _PrivInfo {
sem_t empty;
sem_t full;
char buf[50];
time_t end_time;
}PrivInfo; void info_init(PrivInfo *thiz);
void info_destroy(PrivInfo *thiz);
void *productor(void *paramthiz);
void *consumer(void *paramthiz);
int main (int argc, char** argv) {
pthread_t pt_1 = 0;
pthread_t pt_2 = 0; int ret = 0; PrivInfo *thiz = NULL; thiz = (PrivInfo*)malloc(sizeof(PrivInfo)); if(NULL == thiz) {
return -1;
} info_init(thiz); ret = pthread_create(&pt_1, NULL, productor, (void*)thiz); if(0 != ret) {
perror("pthread1 creation failed!");
}

ret = pthread_create(&pt_2, NULL, consumer,(void*)thiz); if(0 != ret) {
perror("pthread2 creation failed!");
} pthread_join(pt_1, NULL);
pthread_join(pt_2, NULL); info_destroy(thiz);

free(thiz);
thiz = NULL;

return 0;
} void info_init(PrivInfo *thiz) {
return_if_fail(&thiz != NULL); thiz->end_time = time(NULL) 10; sem_init(&thiz->empty, 0, 1);
sem_init(&thiz->full, 0, 0);

memset(thiz->buf, 0, sizeof(thiz->buf));

return;
} void info_destroy(PrivInfo *thiz) {
return_if_fail(&thiz != NULL); sem_destroy(&thiz->empty);
sem_destroy(&thiz->full);

return;
} void *productor(void *paramthiz) {
int i = 0; PrivInfo *thiz = (PrivInfo *)paramthiz; while(time(NULL) < thiz->end_time) {
sem_wait(&thiz->empty);

for(; i<4; i ) {
thiz->buf[i] = 0x41 i;
}

sem_post(&thiz->full); sleep(1);
} pthread_exit(NULL);
} void *consumer(void *paramthiz) {
int numread = 0; PrivInfo *thiz = (PrivInfo *)paramthiz; while(time(NULL) < thiz->end_time) {
sem_wait(&thiz->full); printf("get the string from buffer is: %sn", thiz->buf); sem_post(&thiz->empty); sleep(1);
}

pthread_exit(NULL);
}

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!

分享到：更多

你可能对下面的文章感兴趣

上一篇: 在linux平台上安装DHCP服务器(实验)下一篇: Linux下手工添加用户

关于Linux下多线程编程简介（六）的所有评论

随机推荐