Python-从多个线程追加到同一文件

解决方案是仅在一个线程中写入文件。

import Queue  # or queue in Python 3import threadingclass PrintThread(threading.Thread):    def __init__(self, queue):        threading.Thread.__init__(self)        self.queue = queue    def printfiles(self, p):        for path, dirs, files in os.walk(p): for f in files:     print(f, file=output)    def run(self):        while True: result = self.queue.get() self.printfiles(result) self.queue.task_done()class ProcessThread(threading.Thread):    def __init__(self, in_queue, out_queue):        threading.Thread.__init__(self)        self.in_queue = in_queue        self.out_queue = out_queue    def run(self):        while True: path = self.in_queue.get() result = self.process(path) self.out_queue.put(result) self.in_queue.task_done()    def process(self, path):        # Do the processing job herepathqueue = Queue.Queue()resultqueue = Queue.Queue()paths = getThisFromSomeWhere()output = precs.open('file', 'a')# spawn threads to processfor i in range(0, 5):    t = ProcessThread(pathqueue, resultqueue)    t.setDaemon(True)    t.start()# spawn threads to printt = PrintThread(resultqueue)t.setDaemon(True)t.start()# add paths to queuefor path in paths:    pathqueue.put(path)# wait for queue to get emptypathqueue.join()resultqueue.join()