inst/examples/mpi_napply.r

In RBigData/tasktools: Tools for Task Parallelism with MPI

suppressMessages(library(pbdMPI))
suppressMessages(library(tasktools))

costly = function(x, waittime)
{
  Sys.sleep(waittime)
  cat(paste("iter", x, "executed on rank", comm.rank(), "\n"))
  
  sqrt(x)
}

ret = mpi_napply(10, costly, checkpoint_path="/tmp", preschedule=TRUE, waittime=1)
comm.cat("\n", quiet=TRUE)
comm.print(unlist(ret))

finalize()