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

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

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

Description

The future.mirai package implements the Future API using the mirai package.

Author(s)

Maintainer: Henrik Bengtsson [e-mail] (ORCID) [copyright holder]

Other contributors:

• Charlie Gao [e-mail] (ORCID) (For 'mirai'-related patches and implementing feature requests in 'mirai') [contributor]

See Also

Useful links:

• https://future.mirai.futureverse.org

• https://github.com/futureverse/future.mirai

• Report bugs at https://github.com/futureverse/future.mirai/issues

Examples

plan(mirai_multisession)

# A function that returns a future
# (note that N is a global variable)
f <- function() future({
  4 * sum((runif(N) ^ 2 + runif(N) ^ 2) < 1) / N
}, seed = TRUE)

# Run a simple sampling approximation of pi in parallel using  M * N points:
N <- 1e6  # samples per worker
M <- 10   # iterations
pi_est <- Reduce(sum, Map(value, replicate(M, f()))) / M
print(pi_est)

## Switch back to sequential processing, which also
## shuts down the automatically launched mirai workers 
plan(sequential)

future.mirai documentation built on June 8, 2025, 12:43 p.m.