parallel-processing

0热度

1回答

我发现了一些奇怪的东西：无论出于何种原因，在下面的代码运行后，这个数组版本几乎总是包含随机0，而指针版本不会。 var a = UnsafeMutablePointer<Int>.allocate(capacity: N) //var a = [Int](repeating: 0, count: N) let n = N/iterations DispatchQueue.concurre

0热度

1回答

为什么Rcpp openmp parallized代码有时会给出：分段错误（核心转储）

我写了一个Rcpp代码，在我进行并行处理之前工作。我将代码与openmp并行化。这是我的cppcode： #include <Rcpp.h> #include <omp.h> using namespace Rcpp; // [[Rcpp::export]] float fsvalue(NumericMatrix X1, NumericMatrix X2,int n_cpu=2) {

1热度

1回答

平行中值滤波器

所以我一直在研究中值滤波器*（比较顺序到并行，因为我学习如何并发编码），但并行版本无限期地运行一个大的输入（大约100k;它运行罚款少）。本质上，代码需要一个文件，在给定的窗口大小的情况下对其进行过滤，然后将其写入新文件。并行编程的新手，所以当涉及到什么可能是错误的时候，我有点失落。 //import everything public class SecondMedianFilter ex

-1热度

1回答

Apache Spark：多机器学习的并行化算法

有没有一种方法可以在Spark中并行化多个ML算法。我的用例是这样的： A）并行运行多机器学习算法（朴素贝叶斯，人工神经网络，随机森林等）。 1）使用10倍交叉验证验证每个算法B）在第二层机器学习算法中提供步骤A）的输出。我的问题是：我们可以在步骤A中并行运行多机器学习算法吗？我们可以并行进行交叉验证吗？比如，并行运行10次朴素贝叶斯训练？我无法找到任何方法来并行运行不同的算法。而且似乎交

0热度

1回答

NCCL - 我们可以总结的阵列的所有的值在1个装置GPU以获得总和？

我具有单个GPU（例如的GeForce GTX 980Ti）。我有一个单一的浮阵列，例如，cudaMalloc'ed（分配在该单个装置GPU）长度为128的，与所有值是1.f.我想用nccl将它们相加得到128，即（1 + 1 + ... + 1）= 128。但是，我读了NCCL开发者文档上的减少仅是跨设备，而不能在一个单一的设备，如果我正确地解释它：比照http://docs.nvidia.

0热度

1回答

在并行化的ddply中使用tryCatch（）不起作用

以下代码块仅在ddply未并行化时才起作用;即，ddply(..., .parallel = FALSE)。为什么不在.parallel=TRUE？我有一个计算需要并行化和ddply是完美的，但我似乎无法弄清楚如何使用ddply并行化包括一个tryCatch()语句的函数。这就好像ddply无视代码在tryCatch()内的事实。 # tryCatch in ddply library(ply

0热度

1回答

并行计算glmulti in R in Windows

根据glmulti package document，块是使用多CPU的参数。当使用穷举筛选。但是，即使我在块和块中放入4，并且method ='h'与family ='binomial'，R也只使用单个内核。的函数I用于 glmulti(y~. ,level=1,data=ctrain,fitfunction = 'glm',chunk = 4, chunks = 4,method = '

2热度

1回答

在进程中调用阻塞多进程pool.map

我想在进程内调用multiprocessing.pool.map。当在run()函数中初始化时，它起作用。在初始化时，它不会。我无法确定此行为的原因？在这个过程中会发生什么？我有关python 3.6 from multiprocessing import Pool, Process, Queue def DummyPrinter(key): print(key) clas

0热度

1回答

如何使用RxJava2和Retrofit2创建并行多个非阻塞服务请求

我需要一些帮助来实现使用RxJava2的并行异步调用& Retrofit2。我的要求是; 1）我有多个保险公司（现在我只需要两个），我需要发送多个使用该保险公司名称的并行请求。 2）如果它们中的任何一个给服务器错误，那么其余的请求不应该被阻塞。以下是我到现在为止所尝试的; ArrayList<String> arrInsurer = new ArrayList<>(); arrIn

0热度

1回答

用于Linux/Unix的脚本语言的简单作业调度程序

我定义了一组测试，每个测试可以运行1秒到10分钟。我想在每次提交代码后运行它们。现在顺序运行它们需要很长的时间。是否有任何随时可用的调度程序，它可以帮助我以预定义的并行化程度并行运行这些作业？输入： programms的带有参数调用列表。并行运行的作业数量。输出：与自己返回码一起工作列表（0 OK，-1错误）一般状态（正常或失败 - 如果至少一个作业失败）。运行时间为每个作业（可选）