使用外部包的 foreach 并行计算

如何解决使用外部包的 foreach 并行计算

我自己创建了一个包并尝试将其应用于并行计算。
假设包包含function1 和function2。
我的代码是

cl = makeCluster(2)
registerDoParallel(cl)

foreach(i=1:N,.packages='mypackage') %dopar% {
   res = function1(i)
   res
}
stopCluster(cl)

然后报错，function1在mypackage中。

Error in { : task 1 Failed - "Could not find function "function1""

但是，如果我通过添加更改代码

.export = 'function1'

错误消失。

感谢任何可以解释这一点的人。

解决方法

要么使用 .export 作为 OP 提到的，要么将函数指定为 packageName::functionName

cl = makeCluster(2)
registerDoParallel(cl)

foreach(i=1:N,.packages='mypackage') %dopar% {
   res = mypackage::function1(i)
   res
}
stopCluster(cl)