如何并行化 while 循环？

Question

iter <- 1000
myvec <- c()
while(is.null(myvec) || nrow(myvec) <= iter){
 x = rnorm(10, mean = 0, sd = 1)
 if(sum(x) > 2.5){
    myvec <- rbind(myvec, x)
 }
}

我想并行化上面的 while 循环，我在其中不断迭代，直到我在 myvec 中总共有 iter = 1000 个条目。我在这里查看了 post，但我认为那里的答案不适用于我的示例。

Answer 1

实际上您不需要并行化 while 循环。您可以在 x 上矢量化您的操作，如下所示

iter <- 1000
myvec <- c()
while (is.null(myvec) || nrow(myvec) <= iter) {
  x <- matrix(rnorm(iter * 10, mean = 0, sd = 1), ncol = 10)
  myvec <- rbind(myvec, subset(x, rowSums(x) > 2.5))
}
myvec <- head(myvec, iter)

或

iter <- 1000
myvec <- list()
nl <- 0
while (nl < iter) {
  x <- matrix(rnorm(iter * 10, mean = 0, sd = 1), ncol = 10)
  v <- subset(x, rowSums(x) > 2.5)
  nl <- nl + nrow(v)
  myvec[[length(myvec) + 1]] <- v
}
myvec <- head(do.call(rbind, myvec), iter)

我相信，即使 iter 很大，这也会快得多。

如何并行化 while 循环？

How to parallelize while loops?

parallel-processing

loops

r

while-loop