gooseR (version 0.1.0)

WorkerPool: Worker Pool R6 Class

Description

Manages a pool of async workers

Public fields

n_workers

Number of workers

queue

Query queue

results

Results list

active

Whether pool is active Initialize worker pool

Methods

Public methods

• WorkerPool$new()

• WorkerPool$add()

• WorkerPool$process()

• WorkerPool$get_results()

• WorkerPool$clear_queue()

• WorkerPool$shutdown()

• WorkerPool$clone()

---

Method new()

Usage

WorkerPool$new(n_workers = 4)

Arguments

n_workers

Number of workers Add query to queue

---

Method add()

Usage

WorkerPool$add(query, id = NULL)

Arguments

query

Query to add

id

Optional query ID Process all queued queries

---

Method process()

Usage

WorkerPool$process(progress = TRUE)

Arguments

progress

Show progress

Returns

List of results Get results

---

Method get_results()

Usage

WorkerPool$get_results()

Returns

Results list Clear queue Shutdown pool

---

Method clear_queue()

Usage

WorkerPool$clear_queue()

---

Method shutdown()

Usage

WorkerPool$shutdown()

---

Method clone()

The objects of this class are cloneable with this method.

Usage

WorkerPool$clone(deep = FALSE)

Arguments

deep

Whether to make a deep clone.