Unified Parallel and Distributed Processing in R for Everyone
Create a multicore future whose value will be resolved asynchronously ...
A multicore future is a future whose value will be resolved asynchrono...
A multiprocess future is a future whose value will be resolved asynchr...
Create a multisession future whose value will be resolved asynchronous...
Get the number of workers available
Creates a connection to the system null device
Plan how to resolve a future
Gets the length of an object without dispatching
Functions Moved to 'parallelly'
Create a future
Writes and Reads 'immediateCondition' RDS Files
Request a core for multicore processing
Free up active background workers
Tweak a future function by adjusting its default arguments
Get the first or all references of an object
A future represents a value that will be available at some point in th...
Options used for futures
Back trace the expressions evaluated when an error was caught
Create a cluster future whose value will be resolved asynchronously in...
Export globals to the sticky-globals environment of the cluster nodes
A cluster future is a future whose value will be resolved asynchronous...
A future with a constant value
A condition (message, warning, or error) that occurred while orchestra...
A representation of a set of globals used with futures
Get the future of a future variable
Results from resolving a future
Get all futures in a container
Get future-specific session information and validate current backend
Mandelbrot convergence counts
Inject code for the next type of future to use for nested futures
Retrieves global variables of an expression and their associated packa...
Control whether standard output should be captured or not
Specify globals and packages for a future assignment
Specify label for a future assignment
Control lazy / eager evaluation for a future assignment
Use a specific plan for a future assignment
Set random seed for future assignment
Control whether standard output should be captured or not
Temporarily tweaks the arguments of the current strategy
Resolve one or more futures synchronously
Check whether a future is resolved or not
Get the results of a resolved future
Run a future
Robustly Saves an Object to RDS File Atomically
Create a sequential future whose value will be in the current session
Outputs details on the current session
Signals Captured Conditions
Place a sticky-globals environment immediately after the global enviro...
An uniprocess future is a future whose value will be resolved synchron...
Get number of cores currently used
The value of a future or the values of all elements in a container
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.
Useful links