在 python3 中苦苦挣扎

问：

我正在尝试启动接收器进程。这是一个类，它只从套接字接收数据。例如，它只会在 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 天，无法理解问题所在。我将不胜感激任何信息。

PS 我正在使用进程 bc，我需要非常快速地从套接字接收数据（例如，我只是将数据写入文件）。所以，我不能使用线程。