multiprocessing 相关问题

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

带有类对象的Python多处理池

此代码可以运行 我得到一个空数组“链接” 虽然我应该得到一个包含对象的数组, 当我在 func_b 中打印链接时,它不为空 Self 应该指的是对象,但我猜

回答 1 投票 0

Jupyter 笔记本永远不会使用多处理完成处理(Python 3)

Jupyter 笔记本 我基本上使用多处理模块,我仍在学习多处理的功能。我正在使用达斯蒂·菲利普斯的书,这个代码属于它。 导入

回答 6 投票 0

在Python多处理中执行二进制信号量或互斥体以进行上下文切换操作

我正在尝试自动化win应用程序和java应用程序之间的同步关系。 我的标准是: 启动 win 和 jav 应用程序 在jav应用程序中执行命令 等待jav的回复

回答 1 投票 0

Linux 中的 Fork:释放条件变量时奇怪的无限循环

上下文 系统:Fedora 40 使用的库:pthread.h 详细信息:如果不感兴趣,请阅读“重点” 我很抱歉这里没有提供代码,因为整个程序有超过 4000 行代码......

回答 1 投票 0

将多处理池与采用数组列表的函数结合使用

我正在尝试编写一个函数来并行读取大量文件。我的代码如下: 将 numpy 导入为 np 从多处理导入池 从 functools 导入部分 定义

回答 1 投票 0

Python 多处理抛出无法解释的错误

我有一个python程序,它分为三个文件,dielectric_functions.py,routines.py和cartmoments.py,组织如下-- dielectric_functions.py 是程序的入口点...

回答 1 投票 0

R:通过parallelly::makeClusterPSOCK运行mirai_cluster

我的目标是使用 docker 容器在由多个 Linux 主机组成的集群上的 R 中执行一些繁重的计算。 在 R 中我想使用 foreach。 要做到这一点,我相信最好的方法是使用

回答 1 投票 0

在 python 中打开 gnome 终端会立即显示为僵尸

作为背景,我正在编写一个脚本来训练多个 pytorch 模型。我有一个训练脚本,我希望能够在 gnome 终端中作为子进程运行。主要原因是这样...

回答 1 投票 0

Python 多处理在 slurm 上速度很慢

我正在使用Python多重处理,然后使用sbatch提交作业。 .sh代码如下: #!/bin/bash #------------------------ 开始职位描述 ---------------------- - #SBATCH--

回答 1 投票 0

Python 多处理日志记录错误 - TypeError:需要一个整数(类型为 NoneType)

我一直在开发一个 python3 (3.4.5) 项目,该项目利用 multiprocessing.Pool 通过 4 个工作人员运行大约 50 多个作业。 我有一个单独的进程设置,带有logging.handlers.QueueLi...

回答 3 投票 0

Joblib并行处理在profiling中引入了{内置方法time.sleep}

我正在使用 Joblib 在我的 Python 应用程序中运行并行作业。在分析过程中,我注意到最慢的进程是{内置方法 time.sleep}。有趣的是,当我...

回答 1 投票 0

Starmap 与 tqdm 结合?

我正在做一些并行处理,如下: 将 mp.Pool(8) 作为 tmpPool: 结果 = tmpPool.starmap(my_function, 输入) 其中输入看起来像: [(1,0.2312),(5,0.52) ...] 即,tup...

回答 4 投票 0

如何设法运行具有所有处理器内核的单个处理器项目?

导入多处理、时间 mpCores=multiprocessing.cpu_count() print("这台电脑有", mpCores,"核心数。目前仅使用 1 个,后续升级") tic = time.perf_counter()...

回答 1 投票 0

Python 多处理自更新对象

我正在尝试编写一个基本方向的显示。我有一个以高刷新率运行的界面,以及一个每秒仅更新几次的硬件设备。 我需要能够得到...

回答 1 投票 0

ProcessPoolExecutor:进程池中的进程在 future 正在运行或挂起时突然终止

背景: Python 3.6.5、Django 1.10 我正在尝试使用 ThreadPoolExecutor 和 ProcessPoolExecutor 来减少响应时间,以加快我的 API 速度。添加示例代码: 从 Django 导入数据库 分贝。

回答 1 投票 0

多处理共享内存在进程之间传递大型数组

上下文:我需要分析一年中每个小时的一些天气数据。对于每个小时,我需要在执行一些计算之前读入每个小时的一些输入。这些输入之一是非常...

回答 1 投票 0

Python:当进程工作人员中有 ProcessPoolExecutor 时,使用 QueueHandler 记录到单个文件

我想将来自不同进程的日志添加到单个文件中,其中包含 ProcessPoolExectuor。 我的应用程序具有以下结构: 主要流程 具有进程池的辅助进程:

回答 1 投票 0

Python:当进程工作人员中有 ProcessPoolExecutor 时,使用 QueueHandler 记录到单个文件

我想将来自不同进程的日志添加到单个文件中,其中包含 ProcessPoolExectuor。 我的应用程序具有以下结构: 主要流程 具有进程池的辅助进程:

回答 1 投票 0

为什么迭代会破坏我的文本文件行,而生成器却不会?

对于文本文件的每一行,我想进行大量计算。行数可能有数百万行,因此我使用多重处理: 工人数量 = 1 将 open(my_file, 'r') 作为 f: 与多处理...

回答 1 投票 0

Python:读取文本文件并将行块发送到处理

我有一个文本文件,对于每一行我想做一个相当繁重的计算,并且文件中的行数可能很大(数百万)。 我正在使用多处理。 工人数量 = 1 与开放(

回答 1 投票 0

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