inst/testme/test-nbrOfWorkers.R

In future.mirai: A 'Future' API for Parallel Processing using 'mirai'

#' @tags nbrOfWorkers
#' @tags detritus-files
#' @tags mirai_multisession

library(future.mirai)

message("*** nbrOfWorkers() ...")

ncores <- availableCores()

plan(mirai_multisession)

n <- nbrOfWorkers()
message("Number of workers: ", n)
stopifnot(n == ncores)

plan(sequential)

message("*** nbrOfWorkers() ... DONE")