如何在 Shiny 应用程序结束时终止所有进程？

Question

我正在使用安装了本地服务器的 Shiny。

我的 Shiny 应用使用 system/system2/processx::run 运行繁重的本地程序。我正在同步运行它（等待=T）。如果用户关闭 Shiny 的浏览器窗口，我希望这个繁重的程序结束。如果用户重新打开浏览器窗口，我希望 Shiny 应用再次准备好执行本地程序。

如何做到这一点？

当我使用 system/system2/processx::run 时，应用程序似乎在等待繁重的程序完成并且在关闭时不会停止它。

代表：

library(shiny)
library(processx)

ui <- fluidPage(
  actionButton("runBtn", label="Run a program that consumes many resources") ,
)

server <- function(input, output, session) {
  observeEvent(input$runBtn,
      run("sleep", "240"))
}
shinyApp(ui, server)

当我使用 reprex 关闭浏览器窗口，然后尝试重新打开它时，过程结束需要一些时间。我希望它或多或少立即可用。

附：我正在使用 Linux；系统特定的 hack 很好。

Answer 1

@PorkChop 的评论指出了正确的方向。但是，我建议使用processx::process 而不是run，因为它为我们提供了从R 中控制启动进程的方法。请参阅?process。 （run顺便也是基于进程类的。）

这里的主要问题是，同步运行进程 (wait=TRUE) 会阻塞 R 会话。因此，onStop 在 R 重新控制之前不会触发。 因此，一旦关闭浏览器窗口，您将无法触发任何事情，因为闪亮会话会继续运行，直到外部程序完成并且 R 可以关闭闪亮会话。

在会话结束时，以下代码检查异步启动的进程是否仍然存在，并在必要时将其终止（仅在 Windows 上测试）。

library(shiny)
library(processx)

ui <- fluidPage(
  actionButton("runBtn", label="Run a program that consumes many resources"),
  actionButton("stopSession", "Stop session")
)

server <- function(input, output, session) {
  
  myProcess <- NULL
  
  observeEvent(input$stopSession, {
    cat(sprintf("Closing session %s\n", session$token))
    session$close()
  })
  
  observeEvent(input$runBtn,
               {
                 if(Sys.info()[["sysname"]]=="Windows"){
                   writeLines(text = c("ping 127.0.0.1 -n 60 > nul"), con = "sleep.bat")
                   myProcess <<- process$new("cmd.exe", c("/c", "call", "sleep.bat"), supervise = TRUE, stdout = "")
                 } else {
                   myProcess <<- process$new("sleep", "60", supervise = TRUE, stdout = "")
                 }
                 # myProcess$wait() # wait for the process to finish
               })
  
  onStop(function(){
    cat(sprintf("Session %s was closed\n", session$token))
    if(!is.null(myProcess)){
      if(myProcess$is_alive()){
        myProcess$kill()
      }
    }
    
  })
}

shinyApp(ui, server)

关于不同的会话回调函数见related post。

---

按照此处的要求，该过程包含在reactiveVal：

library(shiny)
library(processx)

ui <- fluidPage(
  actionButton("runBtn", label="Run a program that consumes many resources"),
  actionButton("stopSession", "Stop session")
)

server <- function(input, output, session) {
  
  myProcess <- reactiveVal(NULL)
  
  observeEvent(input$stopSession, {
    cat(sprintf("Closing session %s\n", session$token))
    session$close()
  })
  
  observeEvent(input$runBtn,
               {
                 if(Sys.info()[["sysname"]]=="Windows"){
                   writeLines(text = c("ping 127.0.0.1 -n 60 > nul"), con = "sleep.bat")
                   myProcess(process$new("cmd.exe", c("/c", "call", "sleep.bat"), supervise = TRUE, stdout = ""))
                 } else {
                   myProcess(process$new("sleep", "60", supervise = TRUE, stdout = ""))
                 }
                 # myProcess()$wait() # wait for the process to finish
               })
  
  onStop(function(){
    cat(sprintf("Session %s was closed\n", session$token))
    if(!is.null(isolate(myProcess()))){
      if(isolate(myProcess()$is_alive())){
        isolate(myProcess()$kill())
      }
    }
    
  })
}

shinyApp(ui, server)