为何 python condition acquire 会阻塞线程?
高洛峰
高洛峰 2016-10-28 13:42:48
[Python讨论组]

python 使用 condition 来来同步资源。condition 在文档中描述的是使用 RLock,可重复进入的锁。

今天遇到一个奇怪的问题,condition 在 acquire 时卡住进程了。请教一下大家这种情况怎么解释。

以下是重现问题的代码:

import threading
import Queue
import time

queue = Queue.Queue()
condition = threading.Condition()


def producer():
    while True:
        with condition:
            queue.put(time.time())
        time.sleep(1)


def consumer():
    while True:
        with condition:
            a = queue.get()
            condition.notify()
            print a

threading.Thread(target=producer).start()
threading.Thread(target=consumer).start()


高洛峰
高洛峰

拥有18年软件开发和IT教学经验。曾任多家上市公司技术总监、架构师、项目经理、高级软件工程师等职务。 网络人气名人讲师,...

全部回复(1)
三叔

Queue 自带锁了

你有另外用锁,很容易造成死锁的~

还有,要把sleep改为 cond.wait(),这样,notify()才起作用~


热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号