我的项目涉及使用Julia的 函数并行计算地图。下面是一个最小的例子。映射任务应在1秒后超
浏览 30提问于2020-02-11得票数 1
回答已采纳
3回答
我在cojure REPL中测试了clojure函数映射和pmap，如下所示。这让我很困惑:为什么并行pmap比map慢？user=> (def lg (range 1 10000000))user=> (def lg (range 1 10000000))
user=>
浏览 3提问于2013-11-13得票数 7
在Django视图中，我使用了python的多处理模块，并使用多处理模块的map函数成功地向Julia的服务器发出了并行请求。然而，Julia需要近10分钟来计算1个任务，即使在并行处理之后，它也会消耗大量时间，并且前端必须等待太长时间才能得到最终响应。因此，对于每个对Julia的调用，我需要将计算结果发送回前端，以便它可以开始处理这些数据。 我不想用芹菜。关于如何从子进程本身向前端发送HTTP请求，有什么想法吗？
浏览 34提问于2021-01-12得票数 0
我正在尝试使用Map-Reduce框架编写一个大型程序，它需要将整个过程分成三个Map-Reduce作业，这些作业应该按顺序发生。但我无法链接多个作业，因为每个客户端都需要提供密码并连接到服务器才能执行。我的想法是，通过启动客户端，所有作业都应该按顺序运行。我是python的新手。如果有人能在这方面帮助我，我将不胜感激。s = mincemeat.Server()s.mapfn = map_wordCount
s.reducefn = reduce_wordCountw
浏览 0提问于2013-05-28得票数 3
这里有没有涉及到.NET第三方公共许可证的“任务”？open System;
let start = System.DateTime.Now
let map f l = seq{for a in l do yield f a}
let work f l
浏览 0提问于2011-01-31得票数 8
我想要达到的目标摘要：我引用了进行并行处理。但是我想为单个线程设置一个超时。我知道我可以在最后一行使用重载的get函数。但这将为联合期货设定
浏览 71提问于2022-03-02得票数 4
回答已采纳
我有几个类似的任务，每个任务都有一个超时限制，即必须比指定的时间更快地完成，否则返回一个空结果。这些任务的主要目的是从服务器接收具有超时限制的响应。下面是此类任务的一个示例： public async Task<List<Data>> GetDataWithTimeoutAsync(InputData data, int timeout但是我想并行</e
浏览 14提问于2019-04-24得票数 1
回答已采纳
我有一个函数sim，计算时间很长。我需要运行一个模拟，然后检查一些条件来增加一个单一的变量。@showprogress 1 "Computing ..."在这种情况下，我不太明白如何使用pmap或@parallel，特别是因为我需要增加switches，并且不知道作业是否可以访问该变量。
浏览 0提问于2018-08-16得票数 0
回答已采纳
1回答
我有一个列表，我想用最少的执行次数来执行所有元素的1个繁重的任务。我的解决方案是创建大量的协程，这些协程等同于带有默认调度程序的列表中的元素。示例： async { }假设我有一个包含500个元素的map，并且我的设备最多有4个线程，可以并行运行最多4个繁重的任务。据我所知，将有4个线程并行执行4个任务，当一个线程执行完成时，将有一个任
浏览 0提问于2021-01-08得票数 0
1回答
我正在尝试了解如何使用ipyparallel和jupyter笔记本进行分布式处理，所以我做了一些测试，得到了一些奇怪的结果。len(bview))
results = dview.map= np.sin(data)results = np.sin(data)results = bview.map在这种情况下
浏览 7提问于2017-02-13得票数 1
2回答
我在AWS Step函数中有一个Map任务，它并行执行100-200个lambda，每个lambda运行几分钟，然后收集结果。然而，我遇到了节流，一段时间内并不是所有的lambda都会启动。有没有人有解决这个并发限制的经验？我可以有嵌套的Maps吗，或者我可以将我的任务存储到几个并行运行的Maps中？
浏览 34提问于2020-12-17得票数 2
回答已采纳
4回答
Julia映射函数状态
、、、
是否有一种舒适的方式在朱莉娅获得地图/pmap的“状态”？1:枚举数组并使用if-条件添加打印命令。是，有一种方法可以将匿名函数“链接”到类似的2:知道是否已经存在这样的选项，因为pmap是为并行任务设计的，而并行任务通常用于大型进程，这样它就有了存在的意义吗？示例a = [
浏览 0提问于2016-08-04得票数 2
回答已采纳
2回答
让我们举个例子，假设我有5个包，每个包都有一个方法名process。
我还想为这些线程提供一些超时功能。我将为包的所有线程设置一个默认的超时设置。如果任何包占用的时间比我所拥有的超时设置要长，那么我想超时这些线程，然后登录，说这个包超时
浏览 3提问于2013-08-31得票数 0
回答已采纳
这是在一个api调用中发生的，并且图像上传是顺序的，所以这个api调用花费了太多的时间，并且发生了超时。
有没有办法让它平行呢？因为这个API调用会更频繁，而且每个api调用都有许多图像，所以有人能帮助我改进这个过程吗？
浏览 0提问于2016-02-14得票数 0
0.244354275 | 0.740988568 | 0.197036087 |每个模型的运行都很难并行化，但是通过让每个CPU运行不同的输入模型，并行化应该不会太难。我必须承认，我对Python中的多处理非常陌生，对map、apply和apply_async.之间的区别也不太清楚。这只是一个平庸的例子，因为这里重要的不是模型本身，而是并行运行多个模型。在我的例子中，<
浏览 0提问于2019-04-15得票数 3
1回答
按顺序运行一组任务很棒，看起来像array.sequence(task)(tasks)问题是，在fp-ts中执行并行任务时，限制并发性的惯用方法是什么？例如，Promise.map (在bluebird中)允许您像{concurrency: 4}一样设置并发限制。 一种解决方案可能是将数组拆分为块，然后使用sequence和flatMap迭代这些块。然而，这意味着每个区块中的每个任务都必须在进入下一个区块之前完成-一个长时间<
浏览 18提问于2019-05-09得票数 2
回答已采纳
假设我有以下代码： (doseq [[x y] (map list [1 2] [3 4])] ;; let's imagine those are每次对write-to-disk的调用都会创建一个新文件(或者覆盖它(如果有的话)，尽管这不应该发生)
我该怎么做？
备注:尽管标题是，但这并不是的重复，因为我不
浏览 0提问于2016-02-18得票数 2
回答已采纳
为什么我在mapreduce.map/reduce.ememy.mb中的mapred-site.xml和mapreduce.map/reduce.java.opts上配置的值大于默认值，会使我的工作变慢但是如果我把它配置得太低，那么我的任务就会失败。我认为在这种情况下，我在hadoop上的内存配置是没有必要的……
你能给我一个解释吗？
浏览 0提问于2015-05-13得票数 0
我正在为Julia中的循环寻找不同的编写方式！我知道这是一个基本问题，但我想知道一些不同的选项是什么，以及在性能方面是否有优势/劣势。
浏览 58提问于2019-09-17得票数 2
回答已采纳
假设有10k个简单的直接任务要做，哪一个更好？//method 1range(1, 10k).stream().parallel().map(spark.rdd(x).collect() /*do one using spark*/)
它们是等同的吗？
浏览 1提问于2021-03-19得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
