ToxicMushroom/mare.client
1
0
Fork 0
mirror of https://github.com/Caraxi/mare.client.git synced 2025-12-12 22:17:22 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

it's concurrentdict time

Browse source
This commit is contained in:
Stanley Dimant 2024-11-07 01:00:47 +01:00
parent 973b63cdf1
commit 1b83e7b361
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
MareSynchronos/Services/Mediator/MareMediator.cs
View file

@ -10,15 +10,15 @@ namespace MareSynchronos.Services.Mediator;
public sealed class MareMediator : IHostedService public sealed class MareMediator : IHostedService
{ {
private readonly object _addRemoveLock = new(); private readonly object _addRemoveLock = new();
private readonly Dictionary<object, DateTime> _lastErrorTime = []; private readonly ConcurrentDictionary<object, DateTime> _lastErrorTime = [];
private readonly ILogger<MareMediator> _logger; private readonly ILogger<MareMediator> _logger;
private readonly CancellationTokenSource _loopCts = new(); private readonly CancellationTokenSource _loopCts = new();
private readonly ConcurrentQueue<MessageBase> _messageQueue = new(); private readonly ConcurrentQueue<MessageBase> _messageQueue = new();
private readonly PerformanceCollectorService _performanceCollector; private readonly PerformanceCollectorService _performanceCollector;
private readonly MareConfigService _mareConfigService; private readonly MareConfigService _mareConfigService;
private readonly Dictionary<Type, HashSet<SubscriberAction>> _subscriberDict = []; private readonly ConcurrentDictionary<Type, HashSet<SubscriberAction>> _subscriberDict = [];
private bool _processQueue = false; private bool _processQueue = false;
private readonly Dictionary<Type, MethodInfo?> _genericExecuteMethods = new(); private readonly ConcurrentDictionary<Type, MethodInfo?> _genericExecuteMethods = new();
public MareMediator(ILogger<MareMediator> logger, PerformanceCollectorService performanceCollector, MareConfigService mareConfigService) public MareMediator(ILogger<MareMediator> logger, PerformanceCollectorService performanceCollector, MareConfigService mareConfigService)
{ {
_logger = logger; _logger = logger;