X-Git-Url: https://git.auder.net/?p=talweg.git;a=blobdiff_plain;f=pkg%2FR%2FcomputeForecast.R;h=bd19b8d1297831fda59b3b0da354c2f9576349ec;hp=3537e8a8c2ba090b46989a3aafc88605f2840682;hb=a866acb3c0ae138b22df9dae9ec576b866794417;hpb=5e838b3e17465c376ca075b766cf2543c82e9864

diff --git a/pkg/R/computeForecast.R b/pkg/R/computeForecast.R
index 3537e8a..bd19b8d 100644
--- a/pkg/R/computeForecast.R
+++ b/pkg/R/computeForecast.R
@@ -59,14 +59,26 @@ computeForecast = function(data, indices, forecaster, pjump,
 #oo = forecaster$predictSerie(data, integer_indices[1], memory, horizon, ...)
 #browser()
 
-	library(parallel)
-	ppp <- parallel::mclapply(seq_along(integer_indices), function(i) {
-		list(
-			"forecast" = forecaster$predictSerie(data, integer_indices[i], memory, horizon, ...),
-			"params"= forecaster$getParameters(),
-			"index" = integer_indices[i] )
-		}, mc.cores=3)
-
+	parll=TRUE #FALSE
+	if (parll)
+	{
+		library(parallel)
+		ppp <- parallel::mclapply(seq_along(integer_indices), function(i) {
+			list(
+				"forecast" = forecaster$predictSerie(data, integer_indices[i], memory, horizon, ...),
+				"params"= forecaster$getParameters(),
+				"index" = integer_indices[i] )
+			}, mc.cores=3)
+	}
+	else
+	{
+		ppp <- lapply(seq_along(integer_indices), function(i) {
+			list(
+				"forecast" = forecaster$predictSerie(data, integer_indices[i], memory, horizon, ...),
+				"params"= forecaster$getParameters(),
+				"index" = integer_indices[i] )
+			})
+	}
 #browser()
 
 for (i in seq_along(integer_indices))