我已经阅读了几篇关于Python中多处理的文章，但我不清楚如何使用它们来解决我的问题(我有多个输入和输出)。大多数可用的示例都考虑了结构相当简单的单个输出函数。以下是Python的代码： import numpy as np
i1 = np.random.random(n)i3 = np.random.random# I wan
浏览 13提问于2019-09-09得票数 1
回答已采纳
1回答
将具有多个输入/输出的函数并行化
、、、、
使用以前的答案(merci Booboo)，代码的想法是： ...ylat)) pool.join()
但是geodataframe (Polygon，Point)是不可迭代的，所以我不能使用池，有什么建议可以并行化吗？如何在worker_1中压缩(geodataframe)输出<
浏览 1提问于2021-09-20得票数 0
回答已采纳
1回答
所以用我相当简单的OpenMP并行化for循环，我真的搞不懂这一点。当在相同的输入大小上运行时，P=1运行大约50秒，但是运行P=2需要大约300秒，而P=4运行大约250秒。下面是并行化的循环运行时：p=2，n=1073741824 - 301.66秒
p=4，n=1073741824- 27
浏览 39提问于2020-11-16得票数 1
我有一个关于pmap的使用的问题。我认为这是一个简单/明显的答案，但仍然无法弄清楚！我目前正在运行一个循环，其中50个迭代中的每一个都是分开的，因此并行运行应该是可能的，并且应该提高速度。它使用一个具有多个输入和输出的函数，这些输入和输出是向量和标
浏览 3提问于2015-04-23得票数 0
回答已采纳
1回答
我想在具有不同函数输入的不同线程上多次扩展一个函数。问题是，我的函数需要每次运行不止一个输入，所以我尝试执行以下操作：(这个函数在这里简化了很多)from joblib import Parallel, delayed
#Parallel(n_jobs=4, verbose=1, backend="threading")(map(delayed(work), arg_instance
浏览 0提问于2018-09-14得票数 2
回答已采纳
runtime.GOMAXPROCS(2))：249999750000024999975000002499997500000
我理解MergeByReflection最慢的原因，但是MergeByCode和MergeByGoRoutines之间的区别是什么呢？
浏览 0提问于2015-04-23得票数 4
1回答
如何并行地重复运行一个函数？a = [] a.append(f())
这是的重复，但是，答案并不十分合适，因为它将不同的输入传递到函数中，还给出了向函数传递不同参数<
浏览 0提问于2019-08-20得票数 2
回答已采纳
1回答
我有一个函数来计算适应度值，比如func()。在我的实现中，我使用MPI进行并行化。在这个while循环中，我使用MPI并行化9个func()调用。这意味着，在main循环中调用9次func()，我并行化了三个节点中每个节点调用3个func()调用并将结果返回给主节点的方式。
浏览 2提问于2022-03-07得票数 0
回答已采纳
我有一个for循环，其中调用了一个函数task。对函数的每次调用都返回一个附加到数组中的字符串。我想并行化这个for循环。我试过使用&，但它似乎不起作用。[...] arr+=("$(task $i)")&wait<e
浏览 0提问于2018-07-26得票数 4
因此，我认为有一个问题是很常见的：apply_async()看起来最适合我想做的事情。但是我不能只给出一个回调函数，因为最后我想将所有结果打印到一个文件中。我认为，将打印到单个文件句柄的回调传递给单个文件句柄将导致混乱的结果(甚至不确定是否能够在这样的</e
浏览 7提问于2017-10-19得票数 4
回答已采纳
1回答
我想在一个有滚动窗口的pandas数据框上做一些计算。avg_ret_t = calculate_avg_ret_t(return_matrix, rolling_window, t)在每个for循环中执行的实际函数更加复杂和耗时，因此需要并行化。这个过程可以并行化吗?如果可以，什么是最用户友好的模块？
我意识到潜在的问题是
浏览 1提问于2016-11-05得票数 0
我有一个构建脚本，它的运行速度非常慢，特别是在Solaris上。我想通过在多个作业中运行它来提高它的性能。我该怎么做呢？
浏览 1提问于2013-02-08得票数 3
3回答
每个子目录都有几个文件和一个for循环shell脚本。每个子目录中都有相同的for循环脚本。我想进入每个子目录，在几个终端中并行运行for循环脚本。我试过了，但它似乎是连续的(一个接一个)，但是我想并行地运行它们。
find dir_* -type f -execdir sh for_loop.sh {} \;
浏览 0提问于2017-05-29得票数 9
1回答
这是我的问题。
我已经创建了几个函数，这些函数将是每个 UserID运行的函数(这就是下面运行函数的for循环的原因)。它将在AWS胶水中运行。我需要在Python / AWS中执行可伸缩的--这段代码与数百万UsersID一起工作。由于每个UserID都有3000条记录，那么100万用户总共将达到3000000000条记录。我想到了下面的并行化 for
浏览 5提问于2022-08-25得票数 1
我的输入数据以小块的形式输入，输出被保存到磁盘上的一个文件中。我在寻找输入和输出都最快的策略。在调用create ()之前创建一个更大的输入缓冲区来积累更多的数据是有意义的吗，还是对每个小的输入块调用create()比较好？输入的最佳缓冲区大小(如果有的话)是多少？更快<em
浏览 3提问于2017-05-29得票数 0
1回答
我遵循了本教程：我不确定，但问题可能是事务的输入和输出。我只是用了文档里的那些，我必须要换吗？有一个简短的解释，但我不知道该如何处理它。
编辑:我在文档中找到了这个，这是否意味着我可以使用示例中的那些？通常，必须始终设置至少一个输入和输出，并且这些地址必须遵守
浏览 0提问于2018-10-19得票数 0
回答已采纳
我刚接触Python，
有人知道Python (和函数式语言)函数、map() / reduce()和分布式计算相关的MapReduce概念之间的关系吗？
浏览 2提问于2011-11-14得票数 6
回答已采纳
我正在尝试并行化我为顺序程序编写的函数。下面是输入和输出我希望从输入1中移除输入2中的所有字符串。因此<
浏览 4提问于2016-06-14得票数 2
回答已采纳
1回答
openMP的并行化效率
、、、
我有一个C++代码，其中包含在8线程计算机上与openMP并行的多个for-循环.
，但是单线程的执行速度比并行8线程快。I被告知，如果执行循环的负载增加，并行化将变得高效。在这里，使用load，我的意思是，例如，循环的最大迭代次数。问题是，对于大量的数据，我没有机会比较单线程和8线程并行代码
浏览 2提问于2012-06-26得票数 0
回答已采纳
1回答
我已经创建了一个循环，其中包含一个运行良好的矩阵。函数tkas作为矩阵，并作为输入，计算amtrix列之间的相关性，然后将输出保存在指定的文件夹中。pearson","spearman","kendall")drugCorrelations(methods,mtx,out.folder)但是我还没能把它并行化，这
浏览 8提问于2020-02-21得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
