在 future_lapply 给定的迭代次数后中断代码

Question

我尝试了几个小时来解决这个问题，但直到现在我才找到解决方案。问题如下：我有以下代码和平，我基本上只是检查数据库中提到的 URL 是否更新。每 10 次迭代，我希望代码在 10 次迭代中中断半秒。因此，i=1:9 运行不间断，10:19 会有一个小停顿，20:29 运行通常...

n <- 100
API_expired<- logical(n) 
websites <- organizations$properties.api_path[1:n]
Updated <- function(x){is.null(crunchbase_GET(x))}
Updated_pause <- function(x){is.null(crunchbase_GET(x))
                      sys.sleep(0.5}
cl <- makeCluster(detectCores(), type = "PSOCK")
plan(cluster, workers = cl)

API_expired[1:n]<-  unlist(future_lapply(websites[1:n]))
stopCluster(cl)

Answer 1

你可以使用

if (i %/% 10 %% 2 == 1) { Sys.sleep(0.5) }

确定 10:19、30:39、...范围。

在 future_lapply 给定的迭代次数后中断代码

Interrupting code after given amount of iterations with future_lapply

r

pause