r-"withCallingHandlers"出现并行错误



我有一个类似的并行过程:

library(foreach)
library(doSNOW)
cl = makeCluster(parallel::detectCores() - 1, type = "SOCK", outfile = "out.txt") 
registerDoSNOW(cl)
l = foreach(i = 1:100) %dopar% { 
  res = withCallingHandlers(
    read.csv("somefilethatdoesntexist.csv"), error = function(e) e)
  if(inherits(res, "error")) res = NULL
  res
}

我的期望是,即使"expression"中出现错误,循环也应该继续,但它会带着错误退出,并且不会创建生成的"l"变量。

这种情况似乎尤其与丢失的文件有关。但是,如果我把它包装在tryCatch中,并在"表达式"中进行适当的处理,它怎么会出错呢?

也许这个(从这里改编(:

library(foreach)
library(doSNOW)
cl = makeCluster(parallel::detectCores() - 1, type = "SOCK", outfile = "out.txt") 
registerDoSNOW(cl)
l = foreach(i = 1:2) %dopar% { 
  withCallingHandlers({
      res <- withRestarts( read.csv("somefilethatdoesntexist.csv"),
                          skipError=function() return(NULL))
    },
    error=function(e) {saveRDS(e, paste0("E:/temp/", i, ".rds")); invokeRestart("skipError")})
  res
}
l
#[[1]]
#NULL
#
#[[2]]
#NULL
e <- readRDS("E:/temp/1.rds")
e
#<simpleError in file(file, "rt"): cannot open the connection>

相关内容

  • 没有找到相关文章

最新更新