python-multiprocessing

1热度

2回答

所以基本上我设置了一个事件监听器，它不断地检查Microsoft Outlook，看看有没有新邮件进入我的收件箱。根据收到的电子邮件，我运行某些过程来检查特定电子邮件是否是我们正在寻找的电子邮件（这不需要太多时间），但是如果电子邮件符合我们的标准，我们会在其上运行某个功能，大约需要一两分钟的时间才能完成。我的问题是，我正在收到一封电子邮件在同一时间（自动生成），与我需要的标准，我想运行某些功能。

0热度

1回答

Python - ImportError：用于[module]的加载程序无法处理__mp_main__

我在网上搜索过，无法找到遇到同样问题的任何人。我正在创建一个使用烧瓶作为后端的文件复制器。复制器接收上传的文件并在导出文件之前屏蔽文件中的一些数据。它为用户指定的数量执行此操作。为了加快复制速度，我使用了python的多处理库来加速这个过程，并使它在macOS中工作。但是，当我尝试使用Windows 2008 Server在虚拟机上运行它时，我遇到了一个ImportError。 Tracebac

2热度

1回答

为什么仅在访问多处理特定场景中的共享列表时发生“Broken pipe”错误？

在我开始提问之前，让我提一下我已经知道下面的多处理代码被破坏了。其中有TOCTOU错误。以下代码旨在为我提供教学目的，以便我可以更多地了解代码是如何被破坏的。所以我的问题是关于破碎代码的一个特定方面。首先，让我展示我的代码。现在，您可以完全忽略worker_b，因为我们现在不在任何地方使用它。我们稍后再回来。 import Queue import multiprocessing impor

0热度

1回答

无法从另一个python .py文件运行进程

我正在创建一个类，并且在初始化它时，我正在调用（多进程）它的函数。当我从相同的.py文件创建此类时，一切正常。但是，当我从另一个.py文件初始化此类时 - 它会失败并引发错误...为什么？ MyDummyClass.py： import multiprocessing class MyDummyClass: def __init__(self): print("

1热度

3回答

管理Python的多处理的MongoDB

我试图用多函数运行我的代码，但蒙戈回头率 “MongoClient叉之前打开。与连接=假创建MongoClient，或分叉后创建客户。 “ 我真的不明白我可以如何适应我的代码。基本上结构是： db = MongoClient().database db.authenticate('user', 'password', mechanism='SCRAM-SHA-1') collectionW

1热度

1回答

多处理 - 使用管理者命名空间来保存存储器

我有几个过程需要一个单一的大numpy的阵列中的每个完成任务，这只是被读取（线程正在寻找它为适当的值）。如果每个进程加载的数据我收到一个内存错误。我试图因此通过使用管理器共享的进程之间的同一阵列来最小化存储器的使用。但是我仍然收到一个内存错误。 I 可以在主进程中加载阵列一次，但是当我尝试使其成为属性的管理器名称空间时，我收到一个内存错误。我认为管理者像指针一样行事，并允许独立进程（通常

2热度

1回答

管理调用从瓶应用速率限制API

我具有长颈瓶的应用程序（除其他事项外）必须与速率限制API（即互动，不能使内约有超过X请求的API给定单位时间）。然而，Flask应用程序对API的需求并不均衡 - 有时需求远远超过了API所允许的范围，有时一次不需要几分钟或几小时。它的罚款对API的调用异步发生 - 没有必要为瓶应用程序阻止和等待响应。所以我不知道如何才能最好地实现这一点。我想最好的办法是有一个单独的进程与FIFO队列，这

1热度

1回答

在Python中使用Pool时将kwargs传递给starmap

我正在使用Pool使用starmap多线程程序来传递参数。我坚持，因为我似乎无法找到一种方法，通过kwargs与我传递的星图功能拉链阵列一起。 pool = Pool(NO_OF_PROCESSES) branches = pool.starmap(fetch_api, zip(repeat(project_name), api_extensions)) 分支机构的要求是不完整的为我仍然无

7热度

1回答

Python多处理错误：AttributeError：模块'__main__'没有属性'__spec__'

我正在使用Python 3.6，并试图遵循下面的网站（完整代码也在下面）的第一个例子，以下错误： https://docs.python.org/3.6/library/multiprocessing.html 错误消息： AttributeError: module '__main__' has no attribute '__spec__' 完整的示例代码： from multiprocess

1热度

1回答

使用多处理模块时未看到对对象属性所做的更改

在Python中使用多处理并且您正在导入模块时，为什么模块中的任何实例变量都会通过副本传递给子进程，而参数args()中传递的参数是通过引用传递的。这是否与线程安全有关？ foo.py class User: def __init__(self, name): self.name = name foo_user = User('foo') main.py impo