Тупик в производитель-потребитель с использованием pthreads

Я использую pthreads для решения проблемы производитель-потребитель. По сути, производитель считывает файл в буфер, а потребители (по крайней мере, один, но не ограниченный) берут записи из буфера и обрабатывают их одну за другой. Это производитель:

//...Local stuff...
if(file){
    while(fgets(line, 256, file)){            
        pthread_mutex_lock(&buffer_mutex);            
        while(data->buffer->buffer_items == data->buffer->buffer_size){               
            pthread_cond_wait(&buffer_full_cv, &buffer_mutex);}
        data->buffer->buffer_items);
        reads++;
        add_to_head(data->buffer, line);
        pthread_cond_broadcast(&buffer_ready_cv);            
        pthread_mutex_unlock(&buffer_mutex);            
    }
    pthread_mutex_lock(&buffer_mutex);
    work = 0;
    pthread_mutex_unlock(&buffer_mutex);
    fclose(file);
}

А это потребитель:

//...Local stuff...
while(1){
    pthread_mutex_lock(&buffer_mutex);        
    while(data->buffer->buffer_items == 0){
        if(work)
            pthread_cond_wait(&buffer_ready_cv, &buffer_mutex);            
        else if(!work && !data->buffer->buffer_items)
            pthread_exit(NULL);
    }
    remove_from_tail(data->buffer, string_to_check);
    data->buffer->buffer_items);
    pthread_cond_signal(&buffer_full_cv);
    pthread_mutex_unlock(&buffer_mutex);

    for(unsigned int i = 0; i < data->num_substrings; i++){    
        cur_occurrence = strstr(string_to_check, data->substrings[i]);
        while(cur_occurrence != NULL){
            pthread_mutex_lock(&buffer_mutex);
            data->occurrences[i]++;
            cur_occurrence++;
            cur_occurrence = strstr(cur_occurrence, data->substrings[i]);
            pthread_mutex_unlock(&buffer_mutex);
        }
    }
}

Кажется, что происходит то, что файл полностью прочитан, и есть еще работа, которую нужно выполнить, но поскольку производитель больше не работает, ожидание в потребителе никогда не заканчивается.

PS.: Я также пробовал использовать pthread_cond_signal вместо широковещательной передачи, но это тоже не сработало.

В любом случае, есть ли что-то, что мне здесь не хватает?