python-multiprocessing

3热度

1回答

我不明白它是如何工作的。我有功能log_in有两个参数用户和密码。并有列表与我所有的用户和密码。所以，当我使用p.map（log_in，list）时，这意味着列表将会迭代并“解包”。其中，[ '用户'， 'bitnami']，[ 'USER1'， '12345']等将这些参数log_in（用户，密码）。是吗？ def log_in(user, password): payload =

0热度

1回答

如何在Tkinter父级脚本中实现`input`方法，并将显示的提示和返回值发送回子脚本？

我有两个脚本： Processor_child.py：其目的是执行一些数据分析和清理操作。当单独运行时（不包括Tkinter_parent.py），它必须执行与使用Tkinter_parent.py打包到GUI中时相同的操作。 Tkinter_parent.py：它的目的是为那些无法直接使用Processor_child的用户提供GUI。当我挣扎是从重现蟒蛇input功能Processor_ch

0热度

1回答

使用多处理来处理套接字

我有一个主进程acepting套接字连接的服务器，并将它们放入队列堆栈中，另一个进程监视此堆栈并将其应用于处理连接的池进程。除了一件事情，所有的工作都很好：最后一次连接allways at stuck直到出现另一个连接，它看起来像上次连接无法关闭，但为什么？ from multiprocessing import Queue, Process, Pool, Manager import dat

0热度

4回答

Tkinter的应用“冻结”，同时不断对内容（多）

轮询管我有两个脚本： Processor_child.py：其目的是执行一些数据分析和清理操作。当单独运行时（不包括Tkinter_parent.py），它必须执行与使用Tkinter_parent.py打包到GUI中时相同的操作。 Tkinter_parent.py：它的目的是为那些无法直接使用Processor_child的用户提供GUI。在Processor_child，有for循环，即要

2热度

2回答

多重跟不上结果

我试图运行下面的代码多： import multiprocessing class test(multiprocessing.Process): def __init__(self, name): multiprocessing.Process.__init__(self) self.name = name self.finished = Fals

1热度

1回答

multiprocessing.Pool.map（）删除子类化的ndarray的属性

当从子类numpy.ndarray的子类的实例列表中使用map()从multiprocessing.Pool()时，自己类的新属性被删除。下面的基础上，numpy docs subclassing example小例子，再现了问题： from multiprocessing import Pool import numpy as np class MyArray(np.ndarray):

0热度

2回答

具有两个参数的函数的多处理（池）

所以我有一个函数，它只通过两个参数对几个.txt文件执行一些操作。它目前正在按预期工作，但我在近一个小时内就完成了10％的东西 - 所以需要一些时间，因为.txt文件相当大。现在，我已经阅读了关于程序包多重处理的内容，尤其是其中的Pool段。但是，我不太清楚我如何正确使用它。我用它来运行我的函数的代码如下： for k, structure in enumerate(structures):

0热度

1回答

multiprocessing.Pool.map_async似乎并没有做任何事情吗？

因此，我正在开发一个应用程序，每次启动时都要检查〜50 GB的数据与哈希列表。显然这需要并行化，我不希望应用程序挂在“LOADING ...”屏幕上一分半钟。我正在使用multiprocessing.Pool的map_async来处理这个;主线程调用map_async(checkfiles, path_hash_pairs, callback)并提供一个回调，告诉它在发现不匹配时发出警告。麻烦

0热度

1回答

集成multiprocessing.Process与concurrent.future._base.Future

我有创建子进程，使用未来接收结果，然后杀死其中一些需要时的要求。为此，我分类了multiprocessing.Process类，并从start（）方法返回Future对象。问题是我无法在cb（）函数中接收到结果，因为它永远不会被调用。请帮助/建议如果这可以用其他方式完成，或者我在当前实现中丢失了什么？以下是我目前的做法 from multiprocessing import Process

0热度

1回答

的Python concurrent.futures：在孩子处理异常处理

我有concurrent.futures.ProcessPoolExecutor一个相当普通的香草实现 - 像（使用Python 3.6）： files = get_files() processor = get_processor_instance() with concurrent.futures.ProcessPoolExecutor() as executor: list(e