我有一个 R Shiny 仪表板,其中有 2 个观察者设置为在特定时间刷新,一个观察者每 6 小时刷新一次,另一个每 2 分钟刷新一次。两个观察者都运行一个返回 react 值的函数。这工作正常,但是每 6 小时,当第一个观察者被触发时,它会锁定仪表板并阻止另一个观察者运行。经过一番阅读后,我知道我需要使用 future 和 Promise,但无法实现任何按预期工作的内容。如何将每个观察者中的函数包装到各自的 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()
})
最佳答案
以下是基于您的代码片段的 session 内非阻塞 future 示例:
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)
- 这会向其自己的 session 隐藏 future - 允许 session 内响应。请记住,如果使用错误的方式,此模式可能会导致竞争条件(请参阅 Joe Cheng 的 comment,我在上面已经提到过)
关于r - 如何将阻塞函数包装到 Promise R Shiny 中,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57844507/