Python多处理队列未实现错误MacOS

Python multiprocessing Queue NotImplementedError macOS(Python多处理队列未实现错误MacOS)
本文介绍了Python多处理队列未实现错误MacOS的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

系统信息

  • python3.8.7
  • OS 11.1(大苏尔)
  • 通过brew install python@3.8
  • 安装的Python

要在Big Sur和很可能更旧的版本上复制:

import multiprocessing as mp


if __name__ == '__main__':
    exp_queue = mp.Queue()
    print(exp_queue.qsize())

结果:

  File "/Users/username/Library/Application Support/JetBrains/PyCharm2020.3/scratches/scratch.py", line 5, in <module>
    print(exp_queue.qsize())
  File "/usr/local/Cellar/python@3.8/3.8.7/Frameworks/Python.framework/Versions/3.8/lib/python3.8/multiprocessing/queues.py", line 120, in qsize
    return self._maxsize - self._sem._semlock._get_value()
NotImplementedError

看起来在multiprocessing/queues.py line 120中写这篇文章的人知道这个问题,但我找不到解决方案:

def qsize(self):
    # Raises NotImplementedError on Mac OSX because of broken sem_getvalue()
    return self._maxsize - self._sem._semlock._get_value()

推荐答案

正如Víctor Terrón在GitHub讨论中建议的那样,您可以使用他的实现:

https://github.com/vterron/lemon/blob/d60576bec2ad5d1d5043bcb3111dff1fcb58a8d6/methods.py#L536-L573

根据文件:

多处理的可移植实现。队列。 由于多线程/多处理语义,Queue.qsize()可能 在Mac OS X等Unix平台上引发NotImplementedError异常 其中未实现sem_getvalue()。这个子类解决了这个问题 使用同步的共享计数器(初始化为零)和 每次使用put()和get()方法时增加/减少它的值 分别被称为。这不仅可以防止NotImplementedError 被提出,但也允许我们实现两者的可靠版本 QSize()和Empty()。

这篇关于Python多处理队列未实现错误MacOS的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!

本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!

相关文档推荐

Leetcode 234: Palindrome LinkedList(Leetcode 234:回文链接列表)
How do I read an Excel file directly from Dropbox#39;s API using pandas.read_excel()?(如何使用PANDAS.READ_EXCEL()直接从Dropbox的API读取Excel文件?)
subprocess.Popen tries to write to nonexistent pipe(子进程。打开尝试写入不存在的管道)
I want to realize Popen-code from Windows to Linux:(我想实现从Windows到Linux的POpen-code:)
Reading stdout from a subprocess in real time(实时读取子进程中的标准输出)
How to call type safely on a random file in Python?(如何在Python中安全地调用随机文件上的类型?)