linux线程间通信示例

#include

#include

#include

intbuf[1000000];

intw=0,r=0;//r是读指针，w是写指针

intsize=10;//缓冲区大小

pthread_mutex_tlock;//锁

pthread_cond_tis_empty;//缓冲区是否为空

pthread_cond_tis_full;//缓冲区是否已满

void*sender(void*a)//发送100个数据

{

inti,j,k;

for(i=1;i<=100;i++)//总共100个数据

{

pthread_mutex_lock(&lock);//锁

if(w-r>size)//缓冲区是否已满

pthread_cond_wait(&is_full,&lock);//满了，等待接受线程把数据取走

buf[w++]=i;//缓冲区有空间，发送

printf("%d--->/n",i);//打印出来

pthread_cond_signal(&is_empty);//缓冲区里至少有一个数据，读线程可以把他取走

pthread_mutex_unlock(&lock);//解锁

}

return;

}

void*receiver(void*a)//接受数据

{

intx;

while(1)

{

pthread_mutex_lock(&lock);//锁

if(r==w)//缓冲区是否有数据

pthread_cond_wait(&is_empty,&lock);//没有数据，等待发送线程发数据

x=buf[r++];//有数据了，取走

if(x!=0)

printf("--->%d/n",x);//打印出来

else

break;//数据发送->接受完了，结束线程

pthread_cond_signal(&is_full);//缓冲区至少还有一个空间可以让发送进程发送数据

pthread_mutex_unlock(&lock);//解锁

}

return;

}

intmain()

{

memset(buf,0,sizeof(buf));

pthread_ta,b;//创建两个线程

//初始化

pthread_mutex_init(&lock,NULL);

pthread_cond_init(&is_full,NULL);

pthread_cond_init(&is_empty,NULL);

//线程开始工作

pthread_create(&a,NULL,sender,0);

pthread_create(&b,NULL,receiver,0);

void*recycle;//线程结束时，存放回收的数据

pthread_join(a,&recycle);//回收资源

pthread_join(b,&recycle);//回收资源

return0;

}