我有一個包含郵件地址的文件,我想向其發送電子郵件。我把工作分開了一項讀取文件的任務x 其他發送電子郵件的任務為了在第一個任務和其他任務之間進行通信,我認為使用 FIFO(感謝 posix_mkfifo)將是一個好主意,每個“發送任務”有一個 FIFO,然后循環遍歷它們。由于有時我需要停止腳本,因此我在每次讀取后(在第一個任務中)保存地址文件的偏移量。問題是當我關閉 FIFO 時,偏移量可能在第 500 行(因此 500 個地址通過 FIFO 讀取和發送)但每個任務可能只處理了 5 行。如何防止寫入端關閉 FIFO 以阻止其他任務讓它們處理隊列?
FIFO用于線程之間的通信
ibeautiful
2022-07-16 18:14:25