From 92f11cf466e0e5f14af6b579dfa309a649ab72ef Mon Sep 17 00:00:00 2001 From: Samuele Locatelli Date: Thu, 16 May 2024 15:24:07 +0200 Subject: [PATCH] spostamento delay in coda --- Eqn.Sender/Controllers/fbmsController.cs | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/Eqn.Sender/Controllers/fbmsController.cs b/Eqn.Sender/Controllers/fbmsController.cs index f13ddf4..226184e 100644 --- a/Eqn.Sender/Controllers/fbmsController.cs +++ b/Eqn.Sender/Controllers/fbmsController.cs @@ -245,10 +245,6 @@ namespace Eqn.Sender.Controllers var options = new ParallelOptions { MaxDegreeOfParallelism = numParall }; await Parallel.ForEachAsync(messageList, async (message, token) => { - if (doDelay) - { - await Task.Delay(rnd.Next(15, 25)); - } Stopwatch lsw = new Stopwatch(); var currData = new BStatData(); lsw.Start(); @@ -258,16 +254,17 @@ namespace Eqn.Sender.Controllers currData.Size = message.Tokens.Count; currData.TimeSec = lsw.Elapsed.TotalSeconds; elapsedTime.Add(currData); + // eventuale delay se richiesto + if (doDelay) + { + await Task.Delay(rnd.Next(15, 25)); + } }); } else { foreach (var item in messageList) { - if (doDelay) - { - await Task.Delay(rnd.Next(15, 25)); - } Stopwatch lsw = new Stopwatch(); var currData = new BStatData(); lsw.Start(); @@ -277,6 +274,11 @@ namespace Eqn.Sender.Controllers currData.Size = item.Tokens.Count; currData.TimeSec = lsw.Elapsed.TotalSeconds; elapsedTime.Add(currData); + // eventuale delay se richiesto + if (doDelay) + { + await Task.Delay(rnd.Next(15, 25)); + } } } sw.Stop();