worker_loop_default: Single Task Worker Loop

In rush: Rapid Parallel and Distributed Computing

Single Task Worker Loop

Description

Worker loop that pops a single task from the queue, executes the function and pushes the results.

Usage

worker_loop_default(fun, constants = NULL, rush)

Arguments

fun	(function) Function to be executed.
constants	(list) List of constants passed to fun.
rush	(RushWorker) Rush worker instance.

Value

NULL

Examples

# This example is not executed since Redis must be installed

   config_local = redux::redis_config()
   rush = rsh(network_id = "test_network", config = config_local)

   fun = function(x1, x2, ...) list(y = x1 + x2)
   rush$start_local_workers(
     fun = fun,
     worker_loop = worker_loop_default)

   rush$stop_workers()

rush documentation built on June 22, 2024, 9:38 a.m.