parallel-processing 相关问题

与并发处理形成鲜明对比的是,并行处理保证以并行方式执行所有线程级和/或指令级任务,并保证同时执行的代码路径的完成。

Java8中Iterator和Spliterator的区别

我在学习的过程中了解到并行性是Spliterator的一个主要优点。 这可能是一个基本问题,但任何人都可以向我解释 Iterator 和 Spliterator 之间的主要区别以及......

回答 2 投票 0

如何并行枚举 Rust ndarray 数组? [已关闭]

如何并行枚举 Rust ndarray 数组? 目前我使用: height.indexed_iter_mut().par_bridge() 我相信有一个 API 可以做到这一点,但我只能找到 par_iter 和 par_iter_mut,...

回答 1 投票 0

是否可以有效地并行枚举 rust ndarray 数组? [已关闭]

目前我使用以下低效的解决方法: height.indexed_iter_mut().par_bridge() ndarray 中是否有一个高效的并行迭代器 API 可以生成索引? par_iter 和

回答 1 投票 0

多核CPU上2条指令可以真正同时执行吗

假设x86多核PC架构... 假设有 2 个内核(能够执行 2 个独立的指令流),CPU 和 RAM 之间的接口是内存总线。 可以2

回答 1 投票 0

使用多线程查找具有公共变量的偶数

公开部分课程计划 { 静态 int numberOfOddNumbers = 0; 静态 int numberOfEvenNumbers = 0; 常量 int N = 10000000; 静态 int[] 数字 = new int[N]; 静态int低=...

回答 1 投票 0

依次而不是并行运行许多通配符规则?

这可能听起来像是一个奇怪的要求,但我有一个在超过 150k 个文件上运行规则的工作流程。它们中的大多数可以并行运行,因此我使用通配符。 现在我正处于工作流程中的某个时刻...

回答 1 投票 0

使用 python 和 selenium 并行化网页抓取[编辑和更新]

我正在尝试从巴西健康数据存储库中抓取健康数据。我正在尝试获取 2018 年至 20 年每个月因焦虑/抑郁而去看医生的次数...

回答 1 投票 0

如何通过 GPU 并行(CUDA)打印来跟踪变量

当您并行打印时,(CUDA) 所有线程都会立即触发。 这使得打印输出时很难跟踪变量,因为输出本质上是无序的。 在...

回答 1 投票 0

如何在 Slurm 集群上的多个节点上运行 MPI Python 脚本?错误:警告:无法在 2 个节点上运行 1 个进程,将 nnodes 设置为 1

我正在 Slurm 集群上运行一个脚本,该脚本可以从并行处理中受益,因此我正在尝试实现 MPI。但是,它似乎不允许我在多个节点上运行进程。我不...

回答 1 投票 0

使用 python 和 selenium 并行化网络抓取

我正在尝试从巴西健康数据存储库中获取健康数据。我正在尝试获取 2018 年至 20 年每个月因焦虑/抑郁而去看医生的次数...

回答 1 投票 0

树中的最高和路径

问题描述: 给定一棵通用树,目标是识别并计算从根到具有最大节点值总和的叶子的路径。树中的每个节点都有一个关联的

回答 1 投票 0

在并行运行时获取 mocha 上的原始 process.argv 值

我刚刚升级到mocha 8并启用了测试文件的并行运行。它会生成几个浏览器窗口,因此它可以正常工作,但现在 process.argv 值已更改。 我如何获得原始论据

回答 2 投票 0

为什么需要使用 MPI_probe 查找长度,同时在发送/接收函数中指定消息长度?

以下代码是MPI的实现。正在发送并返回一条长度不断增加的消息。随着每次迭代,消息元素的数量都会增加。 有...

回答 1 投票 0

使用MPI reduce(小写)进行动态流程管理

我想知道在Python中做DPM时是否可以使用MPI的reduce函数(小写)。 目前我有一个工作代码,它明确使用带有Reduce(大写)的内存缓冲区。是

回答 1 投票 0

并行双调排序实现加速

我正在尝试使用 C++ 在 CPU 上实现双调排序的多线程版本。目前,我通过此实现可以获得的最佳加速约为 4.3,(订购 128 MB 的数组)

回答 1 投票 0

如何使用 Python 中列表中的值有条件地更新 Polars DataFrame 中的列?

我正在尝试更新极坐标数据框中的特定行,其中两列(“季节”和“周”)满足某些条件,使用列表或系列中应对齐的值...

回答 1 投票 0

我已将 Flink 升级到 1.19 版本,并且 RichParallelSourceFunction 现已弃用。如何迁移并保持并行性?

我有这段代码,我使用 RichParallelSourceFunction 创建一个实现 SourceFuntion 接口的类。 类 SourceWithSleep(私有 val 输入: List,

回答 2 投票 0

我已将 Flink 升级到 1.9 版本,并且 RichParallelSourceFunction 现已弃用。如何迁移并保持并行性?

我有这段代码,我使用 RichParallelSourceFunction 创建一个实现 SourceFuntion 接口的类。 类 SourceWithSleep(私有 val 输入: List,

回答 1 投票 0

OpenCV 写入的视频文件无法播放

我正在开发一个涉及使用 OpenCV 压缩视频的项目。 导入时间 导入操作系统 将 numpy 导入为 np 导入CV2 进口达斯克 从 dask 导入延迟,计算 导入 dask.bag 作为 db 导入

回答 1 投票 0

OpenCV 视频压缩器无法播放视频文件

我正在开发一个项目,涉及使用 OpenCV 创建视频压缩器。我已经实现了压缩器来运行不同的测试用例。 导入时间 导入操作系统 将 numpy 导入为 np 导入CV2 小鬼...

回答 1 投票 0

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