1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
source("incl/start.R")
if (requireNamespace("future.apply", quietly = TRUE)) {
for (strategy in future_strategies) {
future::plan(strategy)
print(future::plan())
message("* with_progress()")
with_progress({
p <- progressor(4)
y <- future.apply::future_lapply(3:6, function(n) {
p()
slow_sum(1:n, stdout=TRUE, message=TRUE)
})
})
message("* global progression handler")
handlers(global = TRUE)
local({
p <- progressor(4)
y <- future.apply::future_lapply(3:6, function(n) {
p()
slow_sum(1:n, stdout=TRUE, message=TRUE)
})
})
handlers(global = FALSE)
## Explicitly close any PSOCK clusters to avoid 'R CMD check' NOTE
## on "detritus in the temp directory" on MS Windows
future::plan("sequential")
} ## for (strategy ...)
}
source("incl/end.R")
|
