YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-20 19:58:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

increased concurrency to force raceconditions

Browse Source
This commit is contained in:
Eggers Jan
2017-09-13 09:10:41 +02:00
parent 323339b0b2
commit 5712bc11d2
1 changed files with 23 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Tests/MQTTnet.TestApp.NetFramework/PerformanceTest.cs
+23 -13
View File
@@ -7,6 +7,7 @@ using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Text; using System.Text;
using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
namespace MQTTnet.TestApp.NetFramework namespace MQTTnet.TestApp.NetFramework
@@ -16,7 +17,7 @@ namespace MQTTnet.TestApp.NetFramework
public static async Task RunAsync() public static async Task RunAsync()
{ {
var server = Task.Run(() => RunServerAsync()); var server = Task.Run(() => RunServerAsync());
var client = Task.Run(() => RunClientAsync(50, TimeSpan.FromMilliseconds(10))); var client = Task.Run(() => RunClientAsync(500, TimeSpan.FromMilliseconds(10)));
await Task.WhenAll(server, client).ConfigureAwait(false); await Task.WhenAll(server, client).ConfigureAwait(false);
} }
@@ -81,19 +82,11 @@ namespace MQTTnet.TestApp.NetFramework
while (true) while (true)
{ {
for (int i = 0; i < msgChunkSize; i++) var sendTasks = Enumerable.Range( 0, msgChunkSize )
{ .Select( i => PublishSingleMessage( client, ref msgs ) )
var applicationMessage = new MqttApplicationMessage( .ToList();
"A/B/C",
Encoding.UTF8.GetBytes("Hello World"),
MqttQualityOfServiceLevel.AtLeastOnce,
false
);
//do not await to send as much messages as possible await Task.WhenAll( sendTasks );
await client.PublishAsync(applicationMessage);
msgs++;
}
var now = DateTime.Now; var now = DateTime.Now;
if (last < now - TimeSpan.FromSeconds(1)) if (last < now - TimeSpan.FromSeconds(1))
@@ -112,6 +105,23 @@ namespace MQTTnet.TestApp.NetFramework
} }
} }
private static Task PublishSingleMessage( IMqttClient client, ref int count )
{
Interlocked.Increment( ref count );
return Task.Run( () =>
{
var applicationMessage = new MqttApplicationMessage(
"A/B/C",
Encoding.UTF8.GetBytes( "Hello World" ),
MqttQualityOfServiceLevel.AtLeastOnce,
false
);
//do not await to send as much messages as possible
return client.PublishAsync( applicationMessage );
} );
}
private static void RunServerAsync() private static void RunServerAsync()
{ {
try try