我正在尝试启动接收器进程。这是一个类，它只从socket接收数据。例如，它只会在csv文件中写入行。我会通过管道发送出口信号。在该信号之后，单独过程中的while循环将结束，并且该单独的写入器过程将结束。

import multiprocessing
from datetime import datetime
import time
import datetime
import csv
from multiprocessing import Process, Pipe

class CSVWriter:

    def __init__(self, pipe: multiprocessing.Pipe):
        self.pipe = pipe

    def write(self):
        with open(f'RTD.csv', 'w') as csvfile:
            writer = csv.DictWriter(csvfile, delimiter=',', fieldnames=['date'])

            while self.pipe.recv() != 'exit':
                writer.writerow({'date': (datetime.datetime.now())})
                time.sleep(1)
            print('exit csv')

pipe_receiver, pipe_sender = Pipe()

def write_csv(pipe):
    csv_writer = CSVWriter(pipe=pipe)
    csv_writer.write()

process = Process(target=write_csv, args=(pipe_receiver,))
process.start()

pipe_sender.send(input())
process.join()
process.close()

字符串
但是，与我的期望相反，它没有创建文件。或者，如果我输入了错误的退出键，它会创建空文件。
我挣扎与管道大约2天，不能理解的问题。我将非常感谢任何信息。
P.S.我使用的是进程BC，我需要从套接字接收数据非常快（在示例中，我只是将数据写入文件）。所以，我不能使用线程。