为什么这个python队列代码多次处理项目？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了为什么这个python队列代码多次处理项目？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含976字，纯文字阅读大概需要2分钟。

内容图文

以下是我创建的测试用例.为什么每个进程都打印1到5的数字,并且这些数字是不分为进程的数字？

码：

#!/usr/bin/python
from subprocess import *

from Queue import Queue
from Queue import Empty

import multiprocessing
from multiprocessing import Process

def main():
    r = Runner()
    r.run()

class Runner(object):
    processes = []

    def run(self):
        q = Queue()
        for t in range(1,6):
            q.put(t)

        for pi in range(1,4):
            p = Process(target=self.runFromQueue, args=(q,))
            p.start()
            self.processes.append(p)

        for p in self.processes:
            p.join()

        print "Finished!"

    def runFromQueue(self, q):
        try:
            while True:
                number = q.get_nowait()
                print str(number)
                q.task_done()

        except Empty:
            pass


if __name__ == "__main__":
    main()

输出继电器：

$./test_threads.py 
1
2
3
4
5
1
1
2
3
2
4
3
5
4
5
Finished!

预期产量：

$./test_threads.py 
1
2
3
4
5
Finished!

解决方法:

Queue包不是进程感知的,它只适用于线程.您的示例中会发生以下情况：

>创建队列并填写数字
>分叉4个过程.这会将内存内容复制到每个子进程中,包括填充的队列
>每个进程清空其队列副本

您必须使用多处理提供的Queue类.

内容总结

以上是互联网集市为您收集整理的为什么这个python队列代码多次处理项目？全部内容，希望文章能够帮你解决为什么这个python队列代码多次处理项目？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

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

内容手机端