Egalware/eqnfiresend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

spostamento delay in coda

Browse Source
This commit is contained in:
Samuele Locatelli
2024-05-16 15:24:07 +02:00
parent aff6895dcf
commit 92f11cf466
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Eqn.Sender/Controllers/fbmsController.cs
+10 -8
View File
@@ -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();