linux c 多线程 生产者--消费者2
实在不好意思，第一个版本有些问题，是局部变量和堆里面变量的区别。今天做了一下修改。代码如下。
#ifndef _LIST_H_
#define _LIST_H_
#include
#include
#include
struct List
{
char * buffer;
char * cursor;
char * begin;
char * end;
};
// you must add struct, otherwise it will prompt "expected ‘)’ before ‘*’ token"
void init(struct List * p_list);
int get_buffer_length (struct List * p_list);
void put_into_buffer(struct List* p_list,char *pc_char);
char get_from_buffer(struct List* p_list);
#endif
主要是更改了结构体List的定义，buffer必须定义为堆里面的变量。
#include "list.h"
void init(struct List * p_list){
char *temp=(char *)malloc(10);
memset(temp,'\0',10);
p_list->buffer=temp;
p_list->cursor=(p_list->buffer)+10;
p_list->begin=p_list->buffer;
p_list->end=(p_list->buffer)+10;
}
int get_buffer_length(struct List * p_list){
return p_list->end-p_list->cursor;
}
void put_into_buffer(struct List * p_list,char * pc_char){
printf("put ........ %c\n",*pc_char);
if(p_list->cursor<=p_list->begin||p_list->cursor>p_list->end)
printf(" put error\n");
//put the char into cursor's former place
(p_list->cursor)--;
memset(p_list->cursor,(int)(*pc_char),1);
}
char get_from_buffer(struct List * p_list){
if(p_list->cursorbegin||p_list->cursor>p_list->end)
printf(" get error\n");
int length=get_buffer_length(p_list);
printf("list length now is %d\n",length);
(p_list->cursor)++;
char result=*(p_list->end-1);
printf("get ------------------- %c\n",result);
if(length==1)
{
return result;
}
else
{
char *temp=(char *)malloc(10);
bcopy(p_list->cursor-1,temp+10-length+1,length-1);
free(p_list->buffer);
p_list->buffer=temp;
p_list->begin=temp;
p_list->end=temp+10;
p_list->cursor=p_list->end-length+1;
}
return 0;
}
#include
#include
#include
#include
#include "List.h"
pthread_cond_t has_product = PTHREAD_COND_INITIALIZER;
pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
//define the Producer thread
void * produce(void * arg)
{
//arg is a char * pointer
struct List * p_list=(struct List *)arg;
//if buffer length =10,than wait,because buffer is full,
while(1)
{
pthread_mutex_lock(&lock); //正确位置，
//printf("111111\n");
if(get_buffer_length(p_list)==10)
{
//printf("22222222\n");
int num1=pthread_cond_wait(&has_product, &lock);
//printf("33333333\n");
//printf(" num11111 %d\n",num1);
}
//buffer'length !=10,not full, we can put char into buffer.
//printf("444444\n");
//pthread_mutex_lock(&lock); //错误位置
//printf("555555\n");
char zifu=(char)(1+(int)(128.0*rand()/(RAND_MAX+1.0)));
put_into_buffer(p_list,&zifu);
//after put, if the length>0,we can notify the wait thread,means that you can get char now
if(get_buffer_length(p_list)==1)
{
pthread_cond_signal(&has_product);
//printf("66666\n");
}
//printf("777777777777\n");
int num3=pthread_mutex_unlock(&lock);
//printf("unlocknumber 1111111111111 is %d\n",num3);
//printf("888888888888\n");
sleep(1);
//printf("99999999\n");
}
}
//define the second thread
void * comsume(void * arg)
{
//arg is a char * pointer
struct List * p_list=(struct List *)arg;
while(1)
{
//if buffer length =10,than wait,because buffer is full,
pthread_mutex_lock(&lock); //正确位置，
//printf("aaaaaaaaaa\n");
if(get_buffer_length(p_list)==0)
{
//printf("bbbbbbbbbbbbbb\n");
int num2=pthread_cond_wait(&has_product, &lock);
//printf("cccccccccccc\n");
//printf(" num2222 %d\n",num2);
}
//buffer'length !=0,not full, we can get char into buffer.
//printf("dddddddddddddddd\n");
//int num4=pthread_mutex_lock(&lock); //错误位置
//printf("unlocknumber 222222222 is %d\n",num4);
//printf("eeeeeeeeeeeeee\n");
char zifu=get_from_buffer(p_list);
//after get, if the length<10,we can notify the put thread,means that you can put now!
if(get_buffer_length(p_list)<10)
{
pthread_cond_signal(&has_product);
}
//printf("ffffffffffff\n");
pthread_mutex_unlock(&lock);
//printf("gggggggggggg\n");
sleep(2);
// printf("hhhhhhhhhhhhhh\n");
}
}
int main (int argc, char ** argv)
{
pthread_t tidA, tidB;
struct List common;
init(&common);
pthread_create(&tidB, NULL, &comsume, &common);
sleep(3);
pthread_create(&tidA, NULL, &produce, &common);
sleep(120);
return 0;
}
