pool_dispatch: Dispatch Task to Worker

In shard: Deterministic, Zero-Copy Parallel Execution for R

Dispatch Task to Worker

Description

Sends a task to a specific worker and waits for the result.

Usage

pool_dispatch(
  worker_id,
  expr,
  envir = parent.frame(),
  pool = NULL,
  timeout = 3600
)

Arguments

worker_id	Integer. Worker to dispatch to.
expr	Expression to evaluate.
envir	Environment containing variables needed by expr.
pool	A shard_pool object. If NULL, uses the current pool.
timeout	Numeric. Seconds to wait for result (default 3600).

Value

The result of evaluating expr in the worker.

Examples

p <- pool_create(2)
pool_dispatch(1, quote(1 + 1), pool = p)
pool_stop(p)

shard documentation built on April 3, 2026, 9:08 a.m.