小编Axe*_*971的帖子

如何使用 R future 包在集群内进行并行计算?

我想for在集群的节点(几台机器)内分配作业(带有循环)。我尝试使用 R 包future来做到这一点。我不知道这是否是最好的方法;我尝试使用foreachdoParallel包,但没有成功。如何判断循环迭代次数何时大于集群节点数?

library(doParallel);
library(doFuture);
#library(future);

registerDoFuture();

workers <- c(rep("129.20.25.61",1), rep("129.20.25.217",1));
cl <- makeClusterPSOCK(workers, revtunnel = TRUE, outfile = "", verbose = FALSE);

plan(cluster, workers = cl)

mu <- 1.0
sigma <- 2.0

for(i in 1:3){
 res %<-%{ rnorm(i, mean = mu, sd = sigma)}
 print(i);
}
Run Code Online (Sandbox Code Playgroud)

parallel-processing r cluster-computing r-future

3
推荐指数
1
解决办法
2185
查看次数