Python：为什么不同的线程从一个生成器获得自己的一系列值？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Python：为什么不同的线程从一个生成器获得自己的一系列值？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1169字，纯文字阅读大概需要2分钟。

内容图文

我正在学习Python中的多线程.我想知道如何使用生成器向多个线程提供数据.这是我写的：

  import threading

  data = [i for i in xrange(100)]

  def generator():
      for i in data:
          yield i

  class CountThread(threading.Thread):
      def __init__(self, name):
          threading.Thread.__init__(self)
          self.name = name

      def run(self):
          for i in generator():
              print '{0} {1}'.format(self.name, i)

  a = CountThread('a')
  b = CountThread('b')
  a.start()
  b.start()

我以为列表只会被迭代一次.但似乎每个线程都是独立地通过列表进行交互.

输出：

a 0
a 1
a 2
b 0
a 3
a 4
b 1
b 2
a 5
a 6
a 7
a 8
a 9
b 3
b 4
b 5
b 6
b 7
b 8
...
(200 lines)

这是什么原因？如何重写程序,以便列表中的值只打印一次.

解决方法:

您可以使用以下命令在run function中的每个线程中实例化一个新生成器：

for i in generator():

每个生成器调用返回一个新的生成器实例：

>>> data = [i for i in xrange(10)]
>>> a, b = generator(), generator()
>>> id(a), id(b)
(37528032, 37527952)

这里a和b具有不同的id,即使没有线程也会生成相同的结果：

>>> list(a), list(b)
([0, 1, 2, 3, 4, 5, 6, 7, 8, 9], [0, 1, 2, 3, 4, 5, 6, 7, 8, 9])

但请注意,生成器不是线程安全的,在线程应用程序中使用它们很棘手.你必须担心锁定,see example,或者你会得到ValueError：生成器偶尔会执行错误.或者,您可以使用Queue.Queue进行线程通信.

内容总结

以上是互联网集市为您收集整理的Python：为什么不同的线程从一个生成器获得自己的一系列值？全部内容，希望文章能够帮你解决Python：为什么不同的线程从一个生成器获得自己的一系列值？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端