发电机线程安全吗？
我有一个multithreading程序，我创build一个生成器函数，然后将其传递给新的线程。 我希望它是共享/全局性的，所以每个线程可以从生成器中获得下一个值。
使用这样的生成器是否安全，还是会遇到从多个线程访问共享生成器的问题/条件？
如果没有，是否有更好的方法来处理这个问题？ 我需要的东西，将循环通过一个列表，并产生任何线程调用它的下一个值。
这不是线程安全的; 同时通话可能交错，并与本地variables混乱。
常用的方法是使用主从模式（现在称为PC中的农民工模式）。 生成第三个线程来生成数据，并在主服务器和从服务器之间添加一个队列，从服务器将从队列中读取数据，主服务器将向其写入数据。 标准队列模块提供必要的线程安全性，并安排阻塞主机，直到从机准备好读取更多数据。
编辑添加下面的基准。
你可以用一个锁包裹一个发生器。 例如，
import threading class LockedIterator(object): def __init__(self, it): self.lock = threading.Lock() self.it = it.__iter__() def __iter__(self): return self def next(self): self.lock.acquire() try: return self.it.next() finally: self.lock.release() gen = [x*2 for x in [1,2,3,4]] g2 = LockedIterator(gen) print list(g2) locking在我的系统上需要50ms，队列需要350ms。 队列是有用的，当你真的有一个队列; 例如，如果您有传入的HTTP请求，并且您想将它们排队以供工作线程处理。 （这不适合在Python迭代器模型中 – 一旦迭代器用完了项目，就完成了。）如果你确实有一个迭代器，那么LockedIterator是使线程安全的更快，更简单的方法。
from datetime import datetime import threading num_worker_threads = 4 class LockedIterator(object): def __init__(self, it): self.lock = threading.Lock() self.it = it.__iter__() def __iter__(self): return self def next(self): self.lock.acquire() try: return self.it.next() finally: self.lock.release() def test_locked(it): it = LockedIterator(it) def worker(): try: for i in it: pass except Exception, e: print e raise threads = [] for i in range(num_worker_threads): t = threading.Thread(target=worker) threads.append(t) t.start() for t in threads: t.join() def test_queue(it): from Queue import Queue def worker(): try: while True: item = q.get() q.task_done() except Exception, e: print e raise q = Queue() for i in range(num_worker_threads): t = threading.Thread(target=worker) t.setDaemon(True) t.start() t1 = datetime.now() for item in it: q.put(item) q.join() start_time = datetime.now() it = [x*2 for x in range(1,10000)] test_locked(it) #test_queue(it) end_time = datetime.now() took = end_time-start_time print "took %.01f" % ((took.seconds + took.microseconds/1000000.0)*1000)
不，它们不是线程安全的。 您可以在以下位置find关于生成器和multithreading的有趣信息：
这取决于你使用的是哪个python实现。 在CPython中，GIL对python对象进行线程安全的所有操作，因为在任何给定的时间只有一个线程可以执行代码。
