如何将阻塞函数包装到 promise R Shiny 中

Question

我有一个 R Shiny 仪表板，它有 2 个设置为在特定时间刷新的观察者，一个观察者每 6 小时刷新一次，另一个每 2 分钟刷新一次。两个观察者运行一个函数 returns 一个反应值。这工作正常，但是每 6 小时触发第一个观察者时，它会锁定仪表板并阻止另一个观察者运行。阅读一些内容后，我知道我需要使用 futures 和 promises 但无法实现任何按预期工作的东西。我如何将每个观察者中的函数包装到各自的 future 中以防止阻塞？

  values <- reactiveValues()



  observe({

    # Re-execute this reactive expression every 2 mins

    invalidateLater(120000, session)

    values$twominresult <-  twoMinFunction()

  })


  observe({

    # Re-execute this reactive expression every 6 hours

    invalidateLater(21600000, session)

    values$sixhourresult <- sixhourfunction()

  })

Answer 1

这是一个基于您的代码片段的会话内非阻塞期货示例：

library(shiny)
library(promises)
library(future)
plan(multiprocess)

twoMinFunction <- function(){
  return(Sys.time())
}

sixHourFunction <- function(){
  Sys.sleep(3)
  return(Sys.time())
}


server <- function(input, output, session) {

  values <- reactiveValues(twominresult = NULL, sixhourresult = NULL)

  observe({
    # Re-execute this reactive expression every 2 seconds # mins
    invalidateLater(2000, session) # 120000

    myTwoMinFuture <- future({
      twoMinFunction()
    })

    then(myTwoMinFuture, onFulfilled = function(value) {
      values$twominresult <- value
    },
    onRejected = NULL)

    return(NULL)
  })


  observe({
    # Re-execute this reactive expression every 6 seconds # hours
    invalidateLater(6000, session) # 21600000

    mySixHourFuture <- future({
      sixHourFunction()
    })

    then(mySixHourFuture, onFulfilled = function(value) {
      values$sixhourresult <- value
    },
    onRejected = NULL)

    return(NULL)
  })

  output$twominout <- renderText({
    paste("two min result:", values$twominresult)
  })

  output$sixhoursout <- renderText({
    paste("six hour result:", values$sixhourresult)
  })

}

ui <- fluidPage(textOutput("twominout"),
                textOutput("sixhoursout"))

shinyApp(ui, server)

我让它快了一点，所以你可以看到变化。

请注意 observeEvent() 中的 return(NULL) - 这对它自己的会话隐藏了未来 - 允许会话内响应。请记住，如果使用错误的方式，此模式可能会导致竞争条件（请参阅我上面已经提到的 Joe Cheng 的 comment）

如何将阻塞函数包装到 promise R Shiny 中

How do I wrap a blocking function into a promise RShiny

future

r

promise

shiny