tmp-tests/test-foreach2.R

In privefl/bigstatsr: Statistical Tools for Filebacked Big Matrices

l <- list(a = 2)

require(foreach)

test <- function(x, ncores) {
  if (is.seq <- (ncores == 1)) {
    foreach::registerDoSEQ()
  } else {
    cl <- parallel::makeCluster(ncores)
    doParallel::registerDoParallel(cl)
  }
  res <- foreach(i = seq_len(ncores), .combine = 'c') %dopar% {
    x
  }
  if (!is.seq) parallel::stopCluster(cl)
  res
}

print(test(x = l$a, ncores = 2))

test2 <- function(x, ncores) {
  obj <- foreach(i = 1:ncores, .combine = 'c')
  expr_fun <- function(i) {
    x
  }
  foreach2(obj, expr_fun, ncores)
}

print(test2(x = l$a, ncores = 2))