2

我正在尝试链接多个 mclapply/parLapply:

my_function<-function(x){
do something;
mclapply()
}

然后我改变我的 x:

mclapply(1:100,function(i)(function(x[i])),mc.cores=60)

问题是我经常收到以下错误:

调度核 3、57、54、8、23、17、53、18、22、28、41、25、30 在用户代码中遇到错误,所有作业的值都会受到影响

有趣的是,如果我在我的 ubuntu 机器上运行它,我没有收到错误,但是当我在 CentOS 机器上运行它时我收到了这个错误。当我使用 parLapply 执行第二步时,也会发生类似的事情

我也试过:

cl <- makePSOCKcluster(no_cores)
clusterExport(cl,c("function_main_simulation","a1","a2","no_cores"))
system.time(parLapply(cl,1:10000,function(i)(function_main_simulation(a1,a2))))
stopCluster(cl)

但是我又遇到了一些有趣的错误。

4

0 回答 0