适用于Windows的‘'mclapply’

Question

我正在使用https://github.com/mplatzer/BTYDplus/blob/master/R/pareto-nbd-mcmc.r中给出的BTYD plus代码。此代码使用MCMC技术来估计BTYD模型的Pareto/NBD参数。

所以，如果你看到代码的第224-228行，它使用了‘mclapply’函数--我发现这个函数只能在Linux或MAC上运行。我正在windows机器上工作，需要转换这部分代码，以便我能够在Windows机器上执行它。那么，有没有人可以帮我写这个特定的代码，或者给出一个关于如何在windows中使用'mclapply‘的一般概念？

Answer 1

使用parLapply

Sys.info()["sysname"]
#  sysname 
#"Windows"

library(parallel)
cl <- makeCluster(getOption("cl.cores", 2))
l <- list(1, 2)
system.time(
parLapply(cl, l, function(x) {
  Sys.sleep(10)
  })
)
#user  system elapsed 
#0       0      10 

stopCluster(cl)

如果您的任务包含随机数生成，则可能需要查看doRNG包的可重复性。

Answer 2

在并行软件包的文档中，我发现了以下内容：

“作为lapply的类似物，有

parLapply(cl，x，FUN，...)

mclapply(X，FUN，...，mc.cores)

其中mclapply在Windows上不可用...“

第3页，https://stat.ethz.ch/R-manual/R-devel/library/parallel/doc/parallel.pdf

所以我猜parLapply就是你要找的。

警告:我必须说我自己还没有使用过parLapply。我在Windows的R中运行的唯一并行计算是使用foreach包完成的。