Parallel version of lapply using Redis queuing

Usage

rrqlapply(X, FUN, rrq, ..., group = NULL, period = 1, delete_tasks = FALSE, progress_bar = TRUE, env = parent.frame())
rrqlapply_submit(X, FUN, rrq, ..., group = NULL, progress_bar = TRUE, env = parent.frame())

Arguments

X

A vector

FUN

The name of a function to apply to each element of the list. this will change!.

rrq

An rrq object

...

Additional arguments passed to FUN

group

Name of a group for generated task ids. If not included, an ID will be generated.

period

Period to poll for completed tasks. Affects how responsive the function is to quiting, mostly.

delete_tasks

Delete tasks on successful finish?

progress_bar

Display a progress bar?

env

Environment to look in.