My question is related to this question. However the question referenced above uses multicore
package which was replaced by parallel
. Most of the functions in the response cannot be replicated in the parallel
package. Is there a way to track progress in mclapply
. In looking at the mclapply
documentation, there is a parameter called mc.silent
, I'm not sure if this would be able to track progress, and if so how and where we can see the log file? I'm running on ubuntu
linux OS. Please see below for a reproducible example for which I would like to tack progress.
require(parallel)
wait.then.square <- function(xx){
# Wait for one second
Sys.sleep(2);
# Square the argument
xx^2 }
output <- mclapply( 1:10, wait.then.square, mc.cores=4,mc.silent=FALSE)
Any help would be greatly appreciated.
Thanks to the package pbmcapply
you can now easily track progress of mclapply
and mcmapply
jobs. Just replace mclapply
by pbmclapply
:
wait.then.square <- function(xx) {
Sys.sleep(2)
xx^2
}
library(pbmcapply)
output <- pbmclapply(1:10, wait.then.square, mc.cores = 4)
...which will display a pretty progress bar.
The author has a nice blog post on the technical details and performance benchmarks here.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With