麻烦看看这段代码，线程实现生产消费者，哪儿有问题

spxjtu

能运行一段时间，然后报内存的错误，double free，应该是consumer线程的函数，不知道为什么会两次free呢？

#include <stdlib.h>
#include <pthread.h>
#include <stdio.h>
struct msg{
    struct msg *next;
    int   num;
};                        //生产消费的对象
struct msg *head;
pthread_cond_t  has_product = PTHREAD_COND_INITIALIZER;
pthread_mutex_t   lock = PTHREAD_MUTEX_INITIALIZER;
void *consumer(void *p)
{
    struct msg *mp;
    int    i;
    for(i = 0; i < 10; i ++)
    {
        pthread_mutex_lock(&lock);
        while(head == NULL)
            pthread_cond_wait(&has_product, &lock);
        mp = head;
        head = mp -> next;              //消费者取出连表中第一个结构体的数字，然后指针后移
            pthread_mutex_unlock(&lock);
        printf("Consume %d\n", mp -> num);
        free(mp);                       //报错double free，应该就是这句，不知道为什么
        sleep(rand() % 5);       
    }
}
void *producer(void *p)
{
    struct msg *mp;
    struct msg *loc;
    int    i;
    for(i = 0; i < 10; i ++)
    {
        mp = malloc(sizeof(struct msg));
        mp -> num = rand() % 1000 + 1;
        printf("Produce %d\n", mp -> num);
        pthread_mutex_lock(&lock);
        if(head == NULL)               //将生产的结构依次插入head的链表里
        {
            head = mp;
            loc = mp;
        }
        loc -> next = mp;            
        loc = mp;                      //head指向生成的链表的头部，loc指向最后一个元素
        pthread_mutex_unlock(&lock);
        sleep(rand() % 5);       
    }
}
int main(int argc, char ** argv)
{
    pthread_t   pid, cid;
    srand(time(NULL));
    pthread_create(&pid, NULL, producer, NULL);
    pthread_create(&cid, NULL, consumer, NULL);
    pthread_join(pid, NULL);
    pthread_join(cid, NULL);
    return 0;
}

prolj

想都不用想，肯定是同步没有做好。

ydfgic

consumer 没问题，producer明显就是个大bug，lock了没有解锁，逻辑都有问题

peidright

{:3_190:},能运行一段时间，不错啊

spxjtu

回复 3# ydfgic


那个解锁的语句打的时候忘了，不好意思

sunceenjoy

链表些的有问题。第一次，head和head->next都指向同一个，如果consumer能够连续执行当然出问题。还有你mp->next没有赋值，不一定为0,这个时候free也会有问题.

这样试试.
                mp->next        = 0;
        if(head == NULL)               //将生产的结构依次插入head的链表里
        {
            head = mp;
            loc = mp;
                       
        }else{
                        loc -> next = mp;            
                        loc = mp;                      //head指向生成的链表的头部，loc指向最后一个元素
                }

spxjtu

回复 6# sunceenjoy


    多谢啊！我真是大脑短路了，写了if，没写else。

huangwei0413

回复 1# spxjtu


    producer没有调用pthread_cond_signal唤醒consumer啊？