Shiny使用promises实现异步计算报var1不存在错误如何解决

你的代码存在两个核心逻辑错误，导致var1无法被正确识别：

• zeallot包的%<-%是同步解构赋值运算符，不会等待future_promise的异步计算完成，执行到赋值语句时，future_promise返回的只是未完成计算的promise对象，不是你预期的运算结果列表，自然无法解构出var1等变量。
• promise管道%...>%的运行逻辑是将前序promise的最终计算结果作为第一个参数传入后续函数，你将解构赋值写在管道前端、cc_plot(var1)写在管道后端的写法，既没有在异步回调内完成结果解构，cc_plot调用时引用的var1也不在异步回调的作用域内，直接触发找不到对象的错误。

首先需要在应用启动时配置多进程并行策略，才能真正利用多核性能，否则异步代码默认按顺序执行，无法缩短等待时间。所有依赖异步计算结果的操作，都必须放在promise的回调链中执行，Shiny会自动识别render类函数返回的promise对象，在计算完成后更新界面。

基础可用代码 #

library(shiny)
library(future)
library(promises)
library(zeallot)

# 配置多进程并行，workers数量建议设为CPU总核心数-1，留资源给主进程调度
plan(multisession, workers = parallel::detectCores() - 1)

注意：这一步是利用多核性能的核心，默认的并行策略为顺序执行，即使写了异步代码也无法同时处理多个用户的请求

# 服务端逻辑
server <- function(input, output) {
  observeEvent(input$button_press, {
    output$cc_plot <- renderPlot({
      future_promise({
        # 耗时运算放在独立进程中执行
        expensive_operation(arg1, arg2, arg3)
      }) %...>%
        # 拿到异步返回的结果后再做解构、绘图
        (\(calc_res) {
          c(var1, var2, var3, var4, var5) %<-% calc_res
          cc_plot(var1)
        }) %...!%
        # 捕获异步异常，给用户提示
        (\(err) {
          showNotification(paste0("计算失败：", err$message), type = "error")
          NULL
        })
    })
  })
}

多输出优化写法 #

如果你需要用var2-var5更新其他界面元素（文本、表格等），不要把异步计算写在单个renderPlot里，否则每次渲染都会重复执行耗时运算，应该在observeEvent中只触发一次计算，在回调中统一更新所有输出：

observeEvent(input$button_press, {
  # 仅执行一次耗时计算
  calc_future <- future_promise(
    {
      expensive_operation(arg1, arg2, arg3)
    },
    # 如果运算用到自定义函数、外部变量，需要在globals中声明，多进程环境才能识别
    # globals = c("arg1", "arg2", "arg3", "expensive_operation"),
    # 如果运算依赖其他R包，需要在packages中声明
    # packages = c("your_dep_pkg")
  )

  # 统一处理结果，更新所有输出
  calc_future %...>%
    (\(calc_res) {
      c(var1, var2, var3, var4, var5) %<-% calc_res
      # 更新绘图
      output$cc_plot <- renderPlot(cc_plot(var1))
      # 更新其他输出示例：
      # output$summary_text <- renderText(paste0("计算完成，指标值为：", var2))
      # output$result_table <- renderTable(var3)
    }) %...!%
    (\(err) {
      showNotification(paste0("计算失败：", err$message), type = "error")
    })
})

• 不要在异步回调的外部给依赖计算结果的变量赋值，异步回调的执行时机晚于当前同步代码块，外部环境无法读取回调内生成的变量。
• multisession并行策略适配Windows、macOS、Linux全平台，兼容性最好，不建议在Shiny生产环境使用multicore策略（fork多进程容易导致进程崩溃）。
• 如果异步计算用到了全局环境的自定义函数、变量，或者第三方包，必须在future_promise中通过globals和packages参数显式声明，否则多进程环境会报找不到对象的错误。
• 示例代码中用了R4.1.0版本支持的简写匿名函数语法\(x)，如果使用更低版本的R，替换为标准写法function(x)即可。

内容的提问来源于stack exchange，提问作者ixodid