Posix 信号量 =>如何在一段时间后关闭信号量。生产者-消费者问题

Question

我正在通过生产者读取文件，并由消费者将它们写入其他文件，当生产者读取输入文件时，我需要关闭其中一个信号量，并且消费者不再等待生产者将一些新输入插入到缓冲区。有什么办法可以做到这一点吗？

问候...

Answer 1

几种可能性：

• 使用一个标志来指示生产者已完成。解除对信号量的阻止的消费者需要检查该标志并在其设置时进行清理。当生产者设置标志时，它可以向信号量发出足够多的信号以释放任何可能的消费者。您需要小心处理竞争条件，其中某些内容排队等待消费，但在消费者通过检查该标志之前设置了“生产者完成”标志。如果您让消费者线程继续并尝试使工作项出列，但让它们干净地处理即使信号量已发出信号也无事可做的情况，那么这可能很容易处理。 然后让他们查看“生产者完成”标志。
• 使用 pthread_kill() 向任何等待的消费者发送信号。这应该将它们踢出 sem_wait()，在那里它们可以检查 EINTR 返回代码。这也需要仔细编码以避免竞争。我对 POSIX 信号处理不是特别熟悉，但我确信它有自己的一套包袱，您需要非常小心才能正确处理。
• 切换到使用带有互斥锁的条件变量，您可以在保留互斥锁的同时自动检查队列状态和完成条件。

当然，一旦完成，某人（生产者线程？）需要等待所有消费者线程清理 - 可能通过对它们执行 pthread_join() - 在信号量被销毁/关闭之前。

如果您已经使用信号量编码了某些内容，则条件变量选项可能是一个更大的变化，并且在生产和消费（也许）的正常情况下它可能不那么高效。但我敢打赌，推理可能的竞争条件并正确处理它们会更容易。请注意，我并不是说这很容易，只是说它可能会更容易。