api: Add new phase -- concurrency

* R/api.R(concurrency): New function.

* R/resources.R(NO_WORKERS): New parameter.

R/api.R

@@ -187,6 +187,14 @@ vrfy_conf <- function(conf) {
     return(conf)
 }
 
+## @export
+concurrency <- function(m) {
+    m$conf$workers <- if (!is.null(m$conf$workers)) m$conf$workers else NO_WORKERS
+    
+    future::plan("multiprocess",workers=m$conf$workers)
+    message("workers: ",m$conf$workers)
+    m
+}
 
 
 

R/resources.R

@@ -132,3 +132,7 @@ EMPTY_MZML <- dtable(Files=character(0),
 
 
 FN_DATA_TAB <- "data-files.csv"
+
+
+## Default number of concurrent workers
+NO_WORKERS <- 2