amacocian/MTSC
1
0
Fork 0
mirror of https://github.com/AlexMacocian/MTSC.git synced 2026-07-24 03:56:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implemented sequential scheduler

Browse Source
This commit is contained in:
Alexandru Macocian
2020-03-21 12:26:43 +01:00
parent 93b81060d3
commit 2b1bbec49d
3 changed files with 21 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
MTSC/MTSC.csproj
+3 -3
View File
@@ -5,12 +5,12 @@
<TargetFrameworks>netcoreapp2.1;net48;netstandard2.0;netcoreapp3.0</TargetFrameworks>
<ApplicationIcon />
<StartupObject />
<Version>2.1.1</Version>
<Version>2.1.2</Version>
<Authors>Alexandru-Victor Macocian</Authors>
<Product>MTSC</Product>
<Description>Modular TCP Server and Client</Description>
<AssemblyVersion>0.2.1.1</AssemblyVersion>
<FileVersion>0.2.1.1</FileVersion>
<AssemblyVersion>0.2.1.2</AssemblyVersion>
<FileVersion>0.2.1.2</FileVersion>
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
<Platforms>AnyCPU;x64</Platforms>
<PackageProjectUrl>https://github.com/AlexMacocian/MTSC</PackageProjectUrl>
MTSC/ServerSide/Schedulers/SequentialProcessingScheduler.cs
+17
View File
@@ -0,0 +1,17 @@
using System;
using System.Collections.Concurrent;
namespace MTSC.ServerSide.Schedulers
{
public class SequentialProcessingScheduler : IScheduler
{
void IScheduler.ScheduleHandling(IProducerConsumerCollection<(ClientData, Message)> inQueue, Action<ClientData, Message> messageHandlingProcedure)
{
while (inQueue.TryTake(out var tuple))
{
(var client, var message) = tuple;
messageHandlingProcedure.Invoke(client, message);
}
}
}
}
MTSC/ServerSide/Schedulers/TaskAwaiterScheduler.cs
+1 -1
View File
@@ -5,7 +5,7 @@ using System.Threading.Tasks;
namespace MTSC.ServerSide.Schedulers
{
class TaskAwaiterScheduler : IScheduler
public class TaskAwaiterScheduler : IScheduler
{
void IScheduler.ScheduleHandling(IProducerConsumerCollection<(ClientData, Message)> inQueue, Action<ClientData, Message> messageHandlingProcedure)
{