Learn R Programming

⚠️There's a newer version (1.34.0) of this package.Take me there.

future (version 1.6.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(multiprocess)`. This package implements sequential, multicore, multisession, and cluster futures. With these, R expressions can be evaluated on the local machine, on in parallel a set of local machines, or distributed on a mix of local and remote machines. Extensions to this package implements additional backends for processing futures via compute cluster schedulers etc. Because of its unified API, there is no need to modify 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

270,166

Version

1.6.0

License

LGPL (>= 2.1)

Issues

Pull Requests

Stars

Forks

Last Published

August 13th, 2017

Functions in future (1.6.0)

MultiprocessFuture-class

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

An uniprocess future is a future whose value will be resolved synchronously in the current process
availableWorkers

Get set of available workers
backtrace

Back trace the expressions evaluated before a condition was caught
multicore

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

Create a multiprocess future whose value will be resolved asynchronously using multicore or a multisession evaluation
resolve

Resolve one or more futures synchronously
resolved

Check whether a future is resolved or not
tweak

Tweaks a future function by adjusting its default arguments
usedCores

Get number of cores currently used
FutureGlobals

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

An multicore future is a future whose value will be resolved asynchronously in a parallel process
future.options

Options used for futures
futureOf

Get the future of a future variable
%seed%

Set random seed for future assignment
%tweak%

Temporarily tweaks the arguments of the current strategy
run.Future

Run a future
eager

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

The value of a future
values

Gets all values in an object
ClusterFuture-class

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

A future with a constant value
getExpression

Inject code for the next type of future to use for nested futures
%lazy%

Control lazy / eager evaluation for a future assignment
%plan%

Use a specific plan for a future assignment
remote

Create a remote future whose value will be resolved asynchronously in a remote process
getGlobalsAndPackages

Retrieves global variables of an expression and their associated packages
requestCore

Request a core for multicore processing
Future-class

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

An error occurred while trying to evaluate a future
cluster

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

Create a future
%globals%

Specify globals for a future assignment
%label%

Specify label for a future assignment
plan

Plan how to resolve a future
.length

Gets the length of an object without dispatching
sessionDetails

Outputs details on the current R session
supportsMulticore

Check whether multicore processing is supported or not
as.cluster

Coerce an object to a cluster object
availableCores

Get number of available cores on current machine
future_lapply

Apply a Function over a List or Vector via Futures
futures

Gets all futures in an object
makeClusterPSOCK

Create a cluster of R workers for parallel processing
mandelbrot

Mandelbrot convergence counts
multisession

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

Gets the number of workers available