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