DevWiki/websocket-sharp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Modify] Use the Queue<T> class instead

Browse Source
This commit is contained in:
sta 2021-04-11 16:24:04 +09:00
parent 3c9daa9bb0
commit c761dc4c6f
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
websocket-sharp/Net/HttpListener.cs
View File

@ -66,7 +66,7 @@ namespace WebSocketSharp.Net
private string _certFolderPath; private string _certFolderPath;
private Dictionary<HttpConnection, HttpConnection> _connections; private Dictionary<HttpConnection, HttpConnection> _connections;
private object _connectionsSync; private object _connectionsSync;
private List<HttpListenerContext> _contextQueue; private Queue<HttpListenerContext> _contextQueue;
private object _contextQueueSync; private object _contextQueueSync;
private LinkedList<HttpListenerContext> _contextRegistry; private LinkedList<HttpListenerContext> _contextRegistry;
private object _contextRegistrySync; private object _contextRegistrySync;
@ -106,7 +106,7 @@ namespace WebSocketSharp.Net
_connections = new Dictionary<HttpConnection, HttpConnection> (); _connections = new Dictionary<HttpConnection, HttpConnection> ();
_connectionsSync = ((ICollection) _connections).SyncRoot; _connectionsSync = ((ICollection) _connections).SyncRoot;
_contextQueue = new List<HttpListenerContext> (); _contextQueue = new Queue<HttpListenerContext> ();
_contextQueueSync = ((ICollection) _contextQueue).SyncRoot; _contextQueueSync = ((ICollection) _contextQueue).SyncRoot;
_contextRegistry = new LinkedList<HttpListenerContext> (); _contextRegistry = new LinkedList<HttpListenerContext> ();
@ -533,11 +533,7 @@ namespace WebSocketSharp.Net
if (_contextQueue.Count == 0) if (_contextQueue.Count == 0)
return null; return null;
var ret = _contextQueue[0]; return _contextQueue.Dequeue ();
_contextQueue.RemoveAt (0);
return ret;
} }
#endregion #endregion
@ -610,7 +606,7 @@ namespace WebSocketSharp.Net
var ares = getAsyncResultFromQueue (); var ares = getAsyncResultFromQueue ();
if (ares == null) if (ares == null)
_contextQueue.Add (context); _contextQueue.Enqueue (context);
else else
ares.Complete (context); ares.Complete (context);