生产者-消费者模型的结束条件

Question

我正在学习 Pthread 编程。这是我在作业结束时得到的问题：

我想使用producer-consumerproblem 将源文件中的每个字节复制到一个新的.txt 文件中。
这是我的代码结构：

void *producer(....) {
     while(1){
        nsleep();
        read_byte(....);
        nsleep();
        produceToBuffer(....);
     }
}
void *consumer(....) {
     while(1){
        nsleep();
        consumeFromBuffer(....);
        nsleep();
        write_byte(....);
     }
}


int main() {
        pthread_t inThread[nIn];
        pthread_t outThread[nOut];

        //initialize mutex locks for all functions
        pthread_mutex_init(&_mutexConsume, NULL);
        pthread_mutex_init(&_mutexProduce, NULL);
        pthread_mutex_init(&_mutexWrite, NULL);
        pthread_mutex_init(&_mutexRead, NULL);


        sem_init(&empty, 0, size);  //initialize semaphore signal the empty slots available
        sem_init(&full, 0, 0);      //initialize semaphore full signal

        for(i = 0; i < nIn; i++) {
            pthread_create(inThread+i, NULL, producer, null);

        }

        for(j = 0; j < nOut; j++) {
            pthread_create(outThread+i, NULL, consumer, null);

        }
}

我的问题是：生产者线程在文件末尾完成，当检测到 EOF 时为pthread_exit(0);，但对于消费者线程，我的想法是在睡眠后完成或在所有消费者线程等待信号量满时完成。
有人可以帮我吗？

Answer 1

生产者离开后是否有理由让消费者线程保持活动状态？

如果没有，您可以向消费者线程发出信号，不再有生产者线程，并将其用作终止信号，以便您的主线程等待所有生产者线程。

您可以使用pthread_join(producer_thread_id) 等待生产者线程完成，一旦所有生产者线程都完成后，对每个消费者线程使用pthread_cancel(consumer_thread_id) 以中止它们的执行。

使用pthread_create 时需要将每个thread_id 保存到一个数组中，以便将它们用于pthread_cancel 和pthread_join

你可以阅读pthread_joinhere和pthread_cancelhere