zune/MicrosoftIris
0
0
Fork 0
mirror of https://github.com/ZuneDev/MicrosoftIris.git synced 2026-07-27 13:13:29 -07:00
Code Issues Packages Projects Releases Wiki Activity

Use ConcurrentQueue

Browse Source
This commit is contained in:
Yoshi Askharoun
2023-06-01 22:49:47 -05:00
parent c2b9f398e0
commit 3bf297d189
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
UIX/Microsoft/Iris/Debug/SystemNet/NetDebuggerServer.cs
+4 -6
View File
@@ -1,11 +1,9 @@
using Microsoft.Iris.Debug.Data; using Microsoft.Iris.Debug.Data;
using System; using System;
using System.Collections.Generic; using System.Collections.Concurrent;
using System.IO; using System.IO;
using System.Net;
using System.Net.Sockets; using System.Net.Sockets;
using System.Runtime.Serialization; using System.Runtime.Serialization;
using System.Text;
namespace Microsoft.Iris.Debug.SystemNet; namespace Microsoft.Iris.Debug.SystemNet;
@@ -15,7 +13,7 @@ internal class NetDebuggerServer : IDebuggerServer, IDisposable
public Uri ConnectionUri { get; } public Uri ConnectionUri { get; }
private readonly Queue<byte[]> _outQueue = new(); private readonly ConcurrentQueue<byte[]> _outQueue = new();
private readonly TcpListener _listener; private readonly TcpListener _listener;
private readonly IFormatter _formatter; private readonly IFormatter _formatter;
private Socket _socket; private Socket _socket;
@@ -89,9 +87,9 @@ internal class NetDebuggerServer : IDebuggerServer, IDisposable
{ {
while (_socket.Connected) while (_socket.Connected)
{ {
while (_outQueue.Count == 0) ; byte[] frameBytes;
while (!_outQueue.TryDequeue(out frameBytes)) ;
var frameBytes = _outQueue.Dequeue();
_socket.Send(BitConverter.GetBytes(frameBytes.Length)); _socket.Send(BitConverter.GetBytes(frameBytes.Length));
_socket.Send(frameBytes); _socket.Send(frameBytes);
} }