1

我在 R 中有一个很长的任务，它会进行大量计算并写出几个文件。这个函数是从 Shiny-reactive 中调用的。由于这需要很长时间，我想在多个进程上并行化它，但同时我想为最终用户包含一个进度条。我密切关注这篇文章的答案，它使用futures：在并行 foreach 计算中使用标准 R 闪亮进度条。

但是：我的函数创建的文件稍后用于在另一个反应式中进行一些进一步的处理。不知何故，我无法让第二次反应等待，直到我的未来完全完成 - 它已经尝试读取尚未存在或不完整的文件。我如何告诉第二个反应者等到未来完成？

到目前为止我的代码：

library(promises)
library(future)
library(ipc)

plan(multisession)

r1 <- eventReactive(input$go_Button, {
  Runs <- 1:3  #3 parallel runs
  prog <- list()   #Setup for Progressbar
  
  for (j in Runs) {
    prog[[j]] <- AsyncProgress$new(message = "Calculation")
    future_promise({
      for (k in 1:length(rawdata_entries)) {
        prog[[j]]$inc(1 / length(rawdata_entries))
        
        <<< VERY LONG TASK THAT CREATES SEVERAL FILES >>>
          
      }
      prog[[j]]$close()
    }) # end of future_promise
  } # end of for loop
  
  return(list("Done"=TRUE))   
  
}) # end of eventReactive



r2 <- reactive({
  if (r1()$Done == TRUE) {  #my naive approach that doesn't work 
    <<<do some further processing with the files r1() created >>>
    <<< creates the data-frame "some_results" >>>    
  
      return(some_result)
  }
})

我想要实现的最重要的事情是：

  • 并行化耗时的计算
  • 为最终用户提供进度条
  • 在继续下一步之前全面评估承诺

我的错误在哪里/在哪里？

4

0 回答 0