FIFO用于线程之间的通信

Question

我有一个包含邮件地址的文件，我想向其发送电子邮件。我把工作分开了一项读取文件的任务x 其他发送电子邮件的任务为了在第一个任务和其他任务之间进行通信，我认为使用 FIFO（感谢 posix_mkfifo）将是一个好主意，每个“发送任务”有一个 FIFO，然后循环遍历它们。由于有时我需要停止脚本，因此我在每次读取后（在第一个任务中）保存地址文件的偏移量。问题是当我关闭 FIFO 时，偏移量可能在第 500 行（因此 500 个地址通过 FIFO 读取和发送）但每个任务可能只处理了 5 行。如何防止写入端关闭 FIFO 以阻止其他任务让它们处理队列？

Answer 1

我能够通过以读/写方式打开 fifo 而不是仅在第二个任务上读取来解决我的问题