tests/futures.R

In future: Unified Parallel and Distributed Processing in R for Everyone

source("incl/start.R")
library("listenv")

## Backward compatibility
if (getRversion() < "3.2.0") {
  names <- function(x) {
    if (class(x)[1] == "environment") {
      ls(envir = x, all.names = TRUE)
    } else {
      base::names(x)
    }
  }
}

dims <- list(
  NULL,
  c(1, 6),
  c(2, 3),
  c(2, 3, 1),
  c(2, 1, 3, 1)
)


message("*** futures() / resolved() / value() ...")

for (cores in 1:availCores) {
  message(sprintf("Testing with %d cores ...", cores))
  options(mc.cores = cores)

  for (type in c("list", "environment", "listenv")) {
    message(sprintf("Type of object: %s", type))

    for (strategy in supportedStrategies(cores)) {
      message("Type of future: ", strategy)
      plan(strategy)

      for (dim in dims) {
        message("Dimensions: ", deparse(dim))

        if (type == "list") {
          x <- list()
        } else if (type == "listenv") {
          x <- listenv()
        } else if (type == "environment") {
          x <- new.env()
        }

        x$a <- 1
        x$b <- future(2)
        x$c <- future(NULL)
        if (type != "list") x$d %<-% { 4 }
        if (type != "environment") x[[6]] <- 6
        str(x)

        if (!is.null(dim)) {
          if (type != "environment") {
            names <- names(x)
            dim(x) <- dim
            dimnames(x) <- lapply(dim, FUN = function(n) letters[1:n])
            names(x) <- names
          }
        }

        f <- futures(x)
        str(f)
        if (type != "environment") {
          stopifnot(length(f) == length(x))
          stopifnot(identical(names(f), names(x)))
        }
        stopifnot(identical(dim(f), dim(x)))
        stopifnot(identical(dimnames(f), dimnames(x)))

        r <- resolved(x)
        str(r)
        if (type != "environment") {
          stopifnot(length(r) == length(x))
          stopifnot(identical(names(r), names(x)))
        }
        stopifnot(identical(dim(r), dim(x)))
        stopifnot(identical(dimnames(r), dimnames(x)))

        v <- value(x)
        str(v)
        if (type != "environment") {
          stopifnot(length(v) == length(x))
          stopifnot(identical(names(v), names(x)))
        }
        stopifnot(identical(dim(v), dim(x)))
        stopifnot(identical(dimnames(v), dimnames(x)))
      } # for (dim ...)
    } # for (strategy ...)

    message(sprintf("*** futures() - %s ... DONE", type))
  } # for (type ...)

  message(sprintf("Testing with %d cores ... DONE", cores))
} ## for (cores ...)

message("*** futures() / resolved() / value() ... DONE")

source("incl/end.R")