Skip to content

mirai (Race)

Source: R/mirai.R
race_mirai.Rd

Accepts a list of 'mirai' objects, such as those returned by mirai_map(). Waits for the next 'mirai' to resolve if at least one is still in progress, blocking but user-interruptible. If none of the objects supplied are unresolved, the function returns immediately.

Usage

race_mirai(x)

Arguments

x

a 'mirai' object, or list of 'mirai' objects.

Value

The passed object (invisibly).

Details

All of the 'mirai' objects supplied must belong to the same compute profile - the currently-active one i.e. 'default' unless within a with_daemons() or local_daemons() scope.

See also

call_mirai()

Examples

if (FALSE) { # interactive()
daemons(2)
m1 <- mirai(Sys.sleep(0.2))
m2 <- mirai(Sys.sleep(0.1))
start <- Sys.time()
race_mirai(list(m1, m2))
Sys.time() - start
race_mirai(list(m1, m2))
Sys.time() - start
daemons(0)
}