1

我有 2 台具有相同版本的 Ubuntu (16.04)、R (3.4.4) 和未来软件包 (1.10.0) 的机器。我正在运行下面的代码，它实现了异步编程

tic()
library(future)
plan(multisession)
mehAsync = function(){
    future::future({
        Sys.sleep(5)
        return('meh')
    })
}
out = mehAsync()
what = then(out,function(value){(value)})
toc()

预期的行为是执行将几乎立即结束，留下待处理的承诺。在一台机器上发生这种情况，执行会立即发生。但是在我拥有的另一台机器上，执行等待 mehAsync 函数执行，5 秒后完成。

如前所述，两台机器几乎相同。它们之间的主要区别在于速度较慢的是单核机器。但是根据我的理解，该multisession计划不应该需要多个内核。足够的资源来打开机器拥有的新 R 会话。

这里的具体问题是：

  • 我对预期行为的理解是否错误，这对于单核机器来说是正常的吗？
  • 我没有考虑到的其他哪些因素可能会影响这种行为？
  • 由于没有错误/警告消息并且我自己和其他人无法在独立机器中复制，我该如何调试此问题？

注意：在尝试调查其他问题时出现了这个问题

4

1 回答 1

1

计划的默认选项multisession将workers参数 设置availableCores()为单核机器。这意味着如果在使用时不覆盖参数plan，那么内核数量确实很重要。

正在做

plan(multisession,workers=2)

解决了这个问题

于 2018-10-18T00:53:48.327 回答