clustermq (version 0.8.95)

MULTIPROCESS: Process on multiple processes on one machine

Description

Derives from QSys to provide callr-specific functions

Super class

clustermq::QSys -> MULTIPROCESS

Methods

Public methods

• MULTIPROCESS$new()

• MULTIPROCESS$submit_jobs()

• MULTIPROCESS$cleanup()

• MULTIPROCESS$finalize()

• MULTIPROCESS$clone()

• clustermq::QSys$receive_data()

• clustermq::QSys$send_call()

• clustermq::QSys$send_common_data()

• clustermq::QSys$send_job_data()

• clustermq::QSys$send_shutdown_worker()

• clustermq::QSys$send_wait()

• clustermq::QSys$set_common_data()

Method new()

Usage

MULTIPROCESS$new(addr = host("127.0.0.1"), ...)

Method submit_jobs()

Usage

MULTIPROCESS$submit_jobs(
  n_jobs,
  ...,
  log_file = "|",
  log_worker = FALSE,
  verbose = TRUE
)

Method cleanup()

Usage

MULTIPROCESS$cleanup(quiet = FALSE, timeout = 3)

Method finalize()

Usage

MULTIPROCESS$finalize(quiet = FALSE)

Method clone()

The objects of this class are cloneable with this method.

Usage

MULTIPROCESS$clone(deep = FALSE)

Arguments

deep

Whether to make a deep clone.