Akatsuki-Misaki/ArchiSteamFarm
1
0
Fork 0
mirror of https://github.com/JustArchiNET/ArchiSteamFarm.git synced 2026-01-13 15:10:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Further optimize InMemoryServerListProvider and make it thread-safe

Browse Source
This commit is contained in:
JustArchi
2016-08-19 04:57:21 +02:00
parent 214746bca2
commit 2816ecaa90
2 changed files with 19 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
ArchiSteamFarm/InMemoryServerListProvider.cs
View File

@@ -24,7 +24,6 @@
using System;
using System.Collections.Generic;
using System.Diagnostics.CodeAnalysis;
using System.Net;
using System.Threading.Tasks;
using Newtonsoft.Json;
@@ -33,8 +32,7 @@ using SteamKit2.Discovery;
namespace ArchiSteamFarm {
internal sealed class InMemoryServerListProvider : IServerListProvider {
[JsonProperty(Required = Required.DisallowNull)]
[SuppressMessage("ReSharper", "FieldCanBeMadeReadOnly.Local")]
private HashSet<IPEndPoint> Servers = new HashSet<IPEndPoint>();
private readonly ConcurrentHashSet<IPEndPoint> Servers = new ConcurrentHashSet<IPEndPoint>();
internal event EventHandler ServerListUpdated = delegate { };
@@ -46,15 +44,13 @@ namespace ArchiSteamFarm {
return Task.Delay(0);
}
HashSet<IPEndPoint> newEndPoints = new HashSet<IPEndPoint>(endPoints);
if (Servers.SetEquals(newEndPoints)) {
HashSet<IPEndPoint> newServers = new HashSet<IPEndPoint>(endPoints);
if (!Servers.ReplaceIfNeededWith(newServers)) {
return Task.Delay(0);
}
Servers = newEndPoints;
ServerListUpdated(this, EventArgs.Empty);
return Task.Delay(0);
}
}