|
马上注册,结交更多好友,享用更多功能^_^
您需要 登录 才可以下载或查看,没有账号?立即注册
x
在get函数里未定义的引用,怎么调试运行,大佬们顺便帮我把代码详细注释一下有点看不懂。万分感谢!
#include<stdio.h>
#include<stdlib.h>
#include<time.h>
#include<pthread.h>
#define BUFFER_SIZE 16
struct prodcons
{
int buffer[BUFFER_SIZE];
pthread_mutex_t lock;
int readpos,writepos;
pthread_cond_t notempty;
pthread_cond_t notfull;
};
void init(struct prodcons *b)
{
pthread_mutex_init(&b->lock,NULL);
pthread_cond_init(&b->notempty,NULL);
pthread_cond_init(&b->notfull,NULL);
b->readpos=0;
b->writepos=0;
}
void put(struct prodcons *b,int data)
{
pthread_mutex_lock(&b->lock);
while((b->writepos+1)%BUFFER_SIZE == b->readpos)
{
printf("wait for not full\n");
pthread_cond_wait(&b->notfull,&b->lock);
}
b->buffer[b->writepos]=data;
b->writepos++;
if(b->writepos>=BUFFER_SIZE)
b->writepos=0;
pthread_cond_signal(&b->notempty);
pthread_mutex_unlock(&b->lock);
}
int get(struct prodcons *b)
{
int data;
pthread_mutex_lock(&b->lock);
while(b->writepos==b->readpos)
{
printf("wait for not empty\n");
pthread_cond_wait(&b->notempty,&b->lock);
}
data=b->buffer[b->readpos];
b->readpos++;
if(b->readpos>=BUFFER_SIZE)
b->readpos=0;
pthread_cond_siggnal(&b->notfull);
pthread_mutex_unlock(&b->lock);
return data;
}
#define OVER (-1)
struct prodcons buffer;
void *producer(void *data)
{
int n;
for(n=0;n<=1000;n++)
{
printf("put-->%d\n",n);
put(&buffer,n);
}
put(&buffer,OVER);
printf("producer stopped!\n");
return NULL;
}
void *consumer(void *data)
{
int d;
while(1)
{
d=get(&buffer);
if(d==OVER)break;
printf("%d-->get\n",d);
}
printf("consumer stopped!\n");
return NULL;
}
int main()
{
pthread_t th_a,th_b;
void *retval;
init(&buffer);
pthread_create(&th_a,NULL,producer,0);
pthread_create(&th_a,NULL,consumer,0);
pthread_join(&th_a,retval);
pthread_join(&th_a,retval);
return 0;
}
您的代码中出现了一些拼写错误,导致了未定义的引用问题。在 get 函数中, pthread_cond_siggnal 应该是 pthread_cond_signal ,这是一个拼写错误。
此外,您在 main 函数中创建线程时,使用了相同的线程变量 th_a 来创建生产者和消费者线程。这会导致消费者线程无法正确创建。您应该使用不同的线程变量来创建这两个线程。
另外,您在 pthread_join 函数的参数中使用了 & 操作符,这是不正确的。 pthread_join 函数的第一个参数应该是线程变量的地址,而不是地址的地址。
最后,您在 main 函数中调用 pthread_join 函数时,应该分别等待生产者线程和消费者线程的结束,而不是两次等待同一个线程。
以下是修改后的代码:
// ...(原始代码不变)
void *producer(void *data)
{
// ...(原始代码不变)
}
void *consumer(void *data)
{
// ...(原始代码不变)
}
int main()
{
pthread_t th_producer, th_consumer; // 修改线程变量名
void *retval;
init(&buffer);
pthread_create(&th_producer, NULL, producer, 0); // 使用不同的线程变量
pthread_create(&th_consumer, NULL, consumer, 0); // 使用不同的线程变量
pthread_join(th_producer, &retval); // 等待生产者线程结束
pthread_join(th_consumer, &retval); // 等待消费者线程结束
return 0;
}
希望这能帮助到您。如果您有任何其他问题,请随时问我。
|
-
|