1、首先打开vc6.0,新建一个项目。
2、然后我们在编辑框里输入代码添加assert.h头文件。
3、然后我们在编辑框里输入代码添加stdio.h头文件,添加stdlib.h头文件。
4、然后我们在编辑框里输入代码定义结构体ITEM,定义additem函数。
5、然后我们在编辑框里输入代码添加main函数体。
6、然后我们在编辑框里输入代码调用additem函数。
7、运行程序看看结果,此时可以看到程序已经终止了。
面只有两个线程,是生产者/消费者模式,已编译通过,注释很详细。
/* 以生产者和消费者模型问题来阐述Linux线程的控制和通信你
生产者线程将生产的产品送入缓冲区,消费者线程则从中取出产品。
缓冲区有N个,是一个环形的缓冲池。
*/
#include <stdio.h>
#include <pthread.h>
#define BUFFER_SIZE 16
struct prodcons
{
int buffer[BUFFER_SIZE]/*实际存放数据的数组*/
pthread_mutex_t lock/*互斥体lock,用于对缓冲区的互斥 *** 作*/
int readpos,writepos/*读写指针*/
pthread_cond_t notempty/*缓冲区非空的条件变量*/
pthread_cond_t notfull/*缓冲区未满 的条件变量*/
}
/*初始化缓冲区*/
void pthread_init( struct prodcons *p)
{
pthread_mutex_init(&p->lock,NULL)
pthread_cond_init(&p->notempty,NULL)
pthread_cond_init(&p->notfull,NULL)
p->readpos = 0
p->writepos = 0
}
/*将产品放入缓冲区,这里是存入一个整数*/
void put(struct prodcons *p,int data)
{
pthread_mutex_lock(&p->lock)
/*等待缓冲区未满*/
if((p->writepos +1)%BUFFER_SIZE ==p->readpos)
{
pthread_cond_wait(&p->notfull,&p->lock)
}
p->buffer[p->writepos] =data
p->writepos++
if(p->writepos >= BUFFER_SIZE)
p->writepos = 0
pthread_cond_signal(&p->notempty)
pthread_mutex_unlock(&p->lock)
}
/*从缓冲区取出整数*/
int get(struct prodcons *p)
{
int data
pthread_mutex_lock(&p->lock)
/*等待缓冲区非空*/
if(p->writepos == p->readpos)
{
pthread_cond_wait(&p->notempty ,&p->lock)//非空就设置条件变量notempty
}
/*读书据,移动读指针*/
data = p->buffer[p->readpos]
p->readpos++
if(p->readpos == BUFFER_SIZE)
p->readpos = 0
/*设置缓冲区未满的条件变量*/
pthread_cond_signal(&p->notfull)
pthread_mutex_unlock(&p->lock)
return data
}
/*测试:生产站线程将1 到1000的整数送入缓冲区,消费者线程从缓冲区中获取整数,两者都打印信息*/
#define OVER (-1)
struct prodcons buffer
void *producer(void *data)
{
int n
for( n=0n<1000n++)
{
printf("%d ------>\n",n)
put(&buffer,n)
}
put(&buffer,OVER)
return NULL
}
void *consumer(void *data)
{
int d
while(1)
{
d = get(&buffer)
if(d == OVER)
break
else
printf("----->%d\n",d)
}
return NULL
}
int main()
{
pthread_t th_p,th_c
void *retval
pthread_init(&buffer)
pthread_create(&th_p,NULL,producer,0)
pthread_create(&th_c,NULL,consumer,0)
/*等待两个线程结束*/
pthread_join(th_p, &retval)
pthread_join(th_c,&retval)
return 0
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)