requestCore: Request a core for multicore processing
Description
If no cores are available, the current process
blocks until a core is available.Usage
requestCore(await, maxTries = getOption("future::maxTries",
trim(Sys.getenv("R_FUTURE_MAXTRIES", 1000))),
delta = getOption("future::interval", 1), alpha = 1.01)
Arguments
await
A function used to try to "collect"
finished multicore subprocesses.
maxTries
Then maximum number of times subprocesses
should be collected before timeout.
delta
Then base interval (in seconds) to wait
between each try.
alpha
A multiplicative factor used to increase
the wait interval after each try.
Value
- Invisible TRUE. If no cores are available after
extensive waiting, then a timeout error is thrown.