🚤 Parallelizing
This commit is contained in:
parent
cd186f469b
commit
c6bd2c74a6
1 changed files with 4 additions and 2 deletions
|
|
@ -106,7 +106,7 @@ if (!dir.exists(tmp_folder)) {
|
|||
dir.create(tmp_folder, recursive = TRUE)
|
||||
}
|
||||
|
||||
results <- lapply(seq_len(nrow(conditions)), function(idx) {
|
||||
results <- parallel::mclapply(seq_len(nrow(conditions)), function(idx) {
|
||||
current_seed <- conditions[["seeds"]][idx]
|
||||
eps <- conditions[["epsilons"]][idx]
|
||||
max_vem_steps <- conditions[["vem_steps"]][idx]
|
||||
|
|
@ -168,7 +168,9 @@ results <- lapply(seq_len(nrow(conditions)), function(idx) {
|
|||
)
|
||||
)
|
||||
out
|
||||
})
|
||||
},
|
||||
mc.cores = parallelly::availableCores(omit = 1L)
|
||||
)
|
||||
|
||||
to_save <- do.call(rbind, results)
|
||||
filename_to_save <- paste0("impact_vem_", begin_time, ".Rds")
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue