Learn R Programming

future (version 1.34.0)

Unified Parallel and Distributed Processing in R for Everyone

Description

The purpose of this package is to provide a lightweight and unified Future API for sequential and parallel processing of R expression via futures. The simplest way to evaluate an expression in parallel is to use `x %<-% { expression }` with `plan(multisession)`. This package implements sequential, multicore, multisession, and cluster futures. With these, R expressions can be evaluated on the local machine, in parallel a set of local machines, or distributed on a mix of local and remote machines. Extensions to this package implement additional backends for processing futures via compute cluster schedulers, etc. Because of its unified API, there is no need to modify any code in order switch from sequential on the local machine to, say, distributed processing on a remote compute cluster. Another strength of this package is that global variables and functions are automatically identified and exported as needed, making it straightforward to tweak existing code to make use of futures.

Copy Link

Version

Install

install.packages('future')

Monthly Downloads

268,945

Version

1.34.0

License

LGPL (>= 2.1)

Issues

Pull Requests

Stars

Forks

Last Published

July 29th, 2024

Functions in future (1.34.0)

futureSessionInfo

Get future-specific session information and validate current backend
futures

Get all futures in a container
cluster

Create a cluster future whose value will be resolved asynchronously in a parallel process
clusterExportSticky

Export globals to the sticky-globals environment of the cluster nodes
getExpression

Inject code for the next type of future to use for nested futures
future.options

Options used for futures
futureOf

Get the future of a future variable
getGlobalsAndPackages

Retrieves global variables of an expression and their associated packages
find_references

Get the first or all references of an R object
%conditions%

Control whether standard output should be captured or not
%globals%

Specify globals and packages for a future assignment
%stdout%

Control whether standard output should be captured or not
%tweak%

Temporarily tweaks the arguments of the current strategy
%plan%

Use a specific plan for a future assignment
future

Create a future
%label%

Specify label for a future assignment
%seed%

Set random seed for future assignment
mandelbrot

Mandelbrot convergence counts
multicore

Create a multicore future whose value will be resolved asynchronously in a forked parallel process
%lazy%

Control lazy / eager evaluation for a future assignment
nullcon

Creates a connection to the system null device
resetWorkers

Free up active background workers
resolve

Resolve one or more futures synchronously
.length

Gets the length of an object without dispatching
re-exports

Functions Moved to 'parallelly'
sessionDetails

Outputs details on the current R session
plan

Plan how to resolve a future
sequential

Create a sequential future whose value will be in the current R session
tweak

Tweak a future function by adjusting its default arguments
nbrOfWorkers

Get the number of workers available
usedCores

Get number of cores currently used
value

The value of a future or the values of all elements in a container
multisession

Create a multisession future whose value will be resolved asynchronously in a parallel R session
sticky_globals

Place a sticky-globals environment immediately after the global environment
signalConditions

Signals Captured Conditions
readImmediateConditions

Writes and Reads 'immediateCondition' RDS Files
requestCore

Request a core for multicore processing
run.Future

Run a future
result.Future

Get the results of a resolved future
resolved

Check whether a future is resolved or not
save_rds

Robustly Saves an Object to RDS File Atomically
Future-class

A future represents a value that will be available at some point in the future
backtrace

Back trace the expressions evaluated when an error was caught
ConstantFuture-class

A future with a constant value
FutureResult

Results from resolving a future
FutureCondition

A condition (message, warning, or error) that occurred while orchestrating a future
FutureGlobals

A representation of a set of globals used with futures
UniprocessFuture-class

An uniprocess future is a future whose value will be resolved synchronously in the current process
MulticoreFuture-class

A multicore future is a future whose value will be resolved asynchronously in a parallel process
ClusterFuture-class

A cluster future is a future whose value will be resolved asynchronously in a parallel process
MultiprocessFuture-class

A multiprocess future is a future whose value will be resolved asynchronously in a parallel process