修复 writer 的关闭问题
之前在 fsmp.py 按 ctrl-c 取消,或者在调试的时候取消,都要额外终止一下另外一个进程,非常麻烦,有时候还不成功。这里使用 atexit 注册 close 函数,保证一定会调用。
另外我看 pipe 单工性能可能会高一点,看 multiprocessing 的 Queue 里面用的也是单工 pipe。
之前在 fsmp.py 按 ctrl-c 取消,或者在调试的时候取消,都要额外终止一下另外一个进程,非常麻烦,有时候还不成功。这里使用 atexit 注册 close 函数,保证一定会调用。
另外我看 pipe 单工性能可能会高一点,看 multiprocessing 的 Queue 里面用的也是单工 pipe。