rabbitmq.py 文件源码

python
阅读 24 收藏 0 点赞 0 评论 0

项目:Url 作者: beiruan 项目源码 文件源码
def get(self, block=True, timeout=None, ack=False):
        if not block:
            return self.get_nowait()

        start_time = time.time()
        while True:
            try:
                return self.get_nowait(ack)
            except BaseQueue.Empty:
                if timeout:
                    lasted = time.time() - start_time
                    if timeout > lasted:
                        time.sleep(min(self.max_timeout, timeout - lasted))
                    else:
                        raise
                else:
                    time.sleep(self.max_timeout)
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号