我有一个类似的并行过程:
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>