wait_worker: wait_worker Listen to a specific port for workers and assign...

Description Usage Arguments

View source: R/server.R

Description

wait_worker

Listen to a specific port for workers and assign the first job in job queue if the worker asks a job.

Usage

1
2
3
  wait_worker(path = NULL, shared_secret = "default",
    terminate = TRUE, is_start = FALSE,
    is_clear_job_finish = FALSE, ping.time.gap = 10L)

Arguments

path

string, ex: "tcp://*:12345"

shared_secret

string, a secret shares with workers

terminate

logical, whether terminate worker after the job-queue is cleared

is_start

logical, check if the hash value of job under execution is empty or not

is_clear_job_finish

logical, whether clear the list of finished job or not


wush978/RzmqJobQueue documentation built on May 4, 2019, 12:02 p.m.