inst/testme/test-future.R

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

#' @tags future
#' @tags sequential

library(future)

message("*** future() ...")

message("*** future() w/ lazy = TRUE ...")

f <- future({
  42L
}, lazy = TRUE)

print(resolved(f))
y <- value(f)
print(y)
stopifnot(y == 42L)

message("*** future() w/ lazy = TRUE ... DONE")

message("*** future() w/ lazy = TRUE in local() ...")

local({
  a <- 42L
  f <- future({ a }, lazy = TRUE)
  a <- 0L
  y <- value(f)
  print(y)
  stopifnot(y == 42L)
})

message("*** future() w/ lazy = TRUE in local() ... DONE")

message("*** future() w/ gc = TRUE ...")

f <- future(42L, gc = TRUE, lazy = TRUE)
print(f)
y <- value(f)
print(y)
stopifnot(y == 42L)

message("*** future() w/ gc = TRUE ... DONE")
message("*** future() ... DONE")

message("*** future() ...")

f <- future({
  42L
}, lazy = TRUE)

print(resolved(f))
y <- value(f)
print(y)
stopifnot(y == 42L)


message("*** future() w/ gc = TRUE ...")

f <- future(42L, gc = TRUE, lazy = TRUE)
print(f)
y <- value(f)
print(y)
stopifnot(y == 42L)

message("*** future() w/ gc = TRUE ... DONE")


message("*** future() - exceptions ...")

target <- list(name = "<unknown>", envir = new.env(), code = "Yo!", exists = TRUE)
res <- tryCatch(get_future(target, mustExist = TRUE), error = identity)
stopifnot(inherits(res, "error"))

message("*** future() - exceptions ... DONE")

message("*** future() ... DONE")