multiprocessing 相关问题

多处理是在单个计算机系统中使用两个或更多个中央处理单元(CPU)

python 多处理 - 初始化/传递数据库连接以便跨进程使用的最佳方法

我在使用Python多处理包中的pool.map传递数据库连接对象或游标对象时遇到一些困难。基本上,我想创建一个工人池,每个工人都......

回答 3 投票 0

在 Jupyter Notebook 中给出 AttributeError 的多处理示例

我正在尝试在我的代码中实现多处理,因此,我认为我应该从一些示例开始学习。 我使用了本文档中的第一个示例。 来自多重处理

回答 5 投票 0

使用多核提高并行性能

我认为拥有四核计算机的意义在于增加整体性能。但我想知道这种情况到底发生在正常日常计算的哪个阶段。 如果我写 C 代码...

回答 4 投票 0

分离线程与从 main() 调用 pthread_exit(),这两种情况下对资源和内存的影响

我对 C 编程相当陌生,目前正在尝试更广泛地了解 pthreads 库和线程。 问题一: 何时以及为什么分离线程是一个不错的选择...

回答 1 投票 0

分离线程与加入所需线程并从 main() 调用 pthread_exit(),这两种情况下对资源和内存的影响

我对 C 编程相当陌生,目前正在尝试更广泛地了解 pthreads 库和线程。 问题一: 何时以及为什么分离线程是一个不错的选择...

回答 1 投票 0

Python 中的池处理出现索引超出范围错误

我正在运行下面的简单代码来访问全局变量并使用多重处理来操作内容,但即使索引元素存在,它给出的列表索引也超出范围

回答 1 投票 0

为什么pytorch使用polars读取数据时出现‘Unpickling Error’?

我最近将数据工具从 xarray 更改为 Polars,并使用 pl.DataFrame.to_torch() 生成张量来训练我的 Pytorch 模型。数据源的格式是镶木地板文件。 为了避免分叉

回答 1 投票 0

在python中修改子进程中父进程的变量

当我在模块级别定义变量,启动一个新的子进程并在子进程中修改此变量时,更改应该在父进程中可见吗?从我的实验来看,似乎...

回答 1 投票 0

随着额外的 cpu,python 多处理速度会变慢

我正在尝试并行化应该令人尴尬地并行的代码,但我使用的进程越多,它似乎就越慢。 这是一个最小(功能障碍)的示例: 导入操作系统 导入时间 我...

回答 1 投票 0

如何在超时后中止 multiprocessing.Pool 中的任务?

我尝试以这种方式使用python的多处理包: featureClass = [[1000, k, 1] for k in drange(start, end, step)] #参数列表 对于特征类中的 f: pool.apply_async(wo...

回答 2 投票 0

如何将@property与Python ProcessManager一起使用

我有一个带有 @property 的类,并且如果在从另一个函数设置该函数之前访问该属性,则希望引发 RuntimeError 。我现在的问题是,当我在

回答 1 投票 0

Python 线程之间的快速通信

我正在开发一个音频应用程序,其中“音频循环”中的所有函数执行时间都需要<< 1ms. I am aware that Python is not the right programming language for thi...

回答 1 投票 0

仅使用 20 个内核中的 2 个的 Python 多处理程序

我是多重处理新手,所以这可能是一个愚蠢的问题。 我在 Python 3.9.19 下使用 Ubuntu 20.04.6 LTS(64 位)、第 12 代 Intel(R) Core(TM) i7-12700K 处理器和 16GB RAM。什...

回答 1 投票 0

Python 多处理错误:AttributeError:无法在 <module '__main__' (built-in)>”

我正在使用spyder 5.1.5,我正在尝试遵循网站上的第一个示例。 我收到错误: 属性错误:无法在 上获取属性“任务” 我正在使用spyder 5.1.5,我正在尝试遵循网站上的第一个示例。 我收到错误: AttributeError: Can't get attribute 'task' on <module '__main__' (built-in)> task是我定义的函数。 完整示例代码: import multiprocessing import time def task(num): print("a",num) time.sleep(2) if __name__ == '__main__': for i in range(10): p = multiprocessing.Process(target=task,args=(i,)) p.start() 根据Python的文档: 注意: 此软件包中的功能需要 __main__ 模块可以被孩子们导入。这在编程中有介绍 但是,这里值得指出。这意味着一些 示例,例如 multiprocessing.pool.Pool 示例将不起作用 在交互式翻译器中。 Spyder 使用 IPython 控制台,允许您在 IPython 解释器内执行命令并与数据交互。然而,正如 Spyder 维护者所提到的here: “多重处理在 Windows 上的 Spyder 的 IPython 控制台中运行不佳。” 选项1 更新您的 Spyder 软件,因为您使用的是旧版本 - 正如您提到的 5.1.5 版本。但是,如此处所述,“自我们的 5.2.0 版本(于 2021 年 11 月发布)以来,运行多处理代码时生成的打印将被捕获并显示在所有操作系统的 IPython 控制台中”。 选项2 更改控制台设置以使用外部终端运行代码。为此,请访问: Run > Configuration per file... > Execute in an external system terminal(在控制台下)。 选项3 如here所述,您可以将函数写入单独的文件并将其导入脚本中。例如: 任务.py import time def task(num): print("a",num) time.sleep(2) main.py import multiprocessing from tasks import task if __name__ == '__main__': for i in range(10): p = multiprocessing.Process(target=task,args=(i,)) p.start()

回答 1 投票 0

我如何通过调用不同驱动程序中的一个函数来覆盖问题,从而在 selenium python 中使用多处理进行网页抓取

我在网络抓取中需要执行一系列操作,但这花了很多时间,所以我不想一个一个地调用单个函数,而是想将其作为不同的进程传递,如果我这样做,我必须面对

回答 1 投票 0

如何将键盘中断传播到多处理池工作人员并正常退出?

我正在使用Python中的multiprocessing.Pool来并行化一个任务,该任务需要为工作负载中的每个项目进入和退出上下文管理器。我想确保当键盘中断时

回答 1 投票 0

我使用了 2 个工作池来通过 Python 多处理在函数中分割总和,但时间并没有加快,是我遗漏了什么吗?

下面提供了Python代码文件。我在 Linux mint 21.3 上使用 Python 3.10.12(以防需要这些信息)。有 2 名工人的工人比没有工人的工人需要更多时间

回答 2 投票 0

我使用了 2 个工作线程池来分割 Python 函数中的总和,但时间并没有显示出任何加速,有什么特别的东西我错过了吗?

下面提供了Python代码文件。我在 Linux mint 21.3 上使用 Python 3.10.12(以防需要这些信息)。有 2 名工人的工人比没有工人的工人需要更多时间

回答 1 投票 0

子进程可以创建共享内存并与父进程共享吗?

子进程可以创建SharedMemory对象并与父进程共享吗?目前,我在尝试时遇到错误。我需要这个,因为创建和复制内存是主要性能

回答 1 投票 0

pymongo 在使用多处理时抛出 WinError 10048

我在多处理中使用 pymongo。我使用6个进程来计算一些东西并将计算结果插入到MongoDB中。 导入多重处理 导入系统 导入 pymongo 导入日期时间 来自

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.