Question

我试图在几个核心上操作编码(我尝试了<条码>snow和<条码>第包)。我

cl <- makeCluster(2)
y  <- 1:10
sapply(1:5, function(x) x + y)  # Works
parSapply(cl, 1:5, function(x) x + y)

最后一行将错误归为:

Error in checkForRemoteErrors(val) : 
  2 nodes produced errors; first error: object  y  not found

显然parSapply 页: 1 如何解决这一问题? 感谢。

Answer 1

这些节点不知道主人全球环境中的<代码>y。你们需要告诉他们。

library(parallel)
cl <- makeCluster(2)
y  <- 1:10
# add y to function definition and parSapply call
parSapply(cl, 1:5, function(x,y) x + y, y)
# export y to the global environment of each node
# then call your original code
clusterExport(cl, "y")
parSapply(cl, 1:5, function(x) x + y)

Answer 2

值得一提的是,如果在职能范围内要求<代码>parSapply,则您的榜样将发挥作用,尽管实际问题在于建立<代码>功能(x)×+<。例如,以下法典是正确的:

library(parallel)
fun <- function(cl, y) {
  parSapply(cl, 1:5, function(x) x + y)
}
cl <- makeCluster(2)
fun(cl, 1:10)
stopCluster(cl)

这是因为,其他职能所产生的职能与创建这些职能的地方环境相呼应,而全球环境所产生的职能则没有与全球环境同步进行。这有时会有所助益,但如果你不了解这个问题,也会带来各种问题。

友情链接