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()
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.