Alex-Devera/v2rayN
1
0
Fork 0
mirror of https://github.com/2dust/v2rayN.git synced 2025-07-01 12:32:10 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

use Task.Delay instead of Thread.Sleep

Browse source
This commit is contained in:
2dust 2023-05-21 16:30:05 +08:00
parent abe484b0df
commit 566f056149
1 changed files with 16 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
v2rayN/PacLib/PacHandler.cs
View file

@ -2,7 +2,6 @@
using System.IO; using System.IO;
using System.Net.Sockets; using System.Net.Sockets;
using System.Text; using System.Text;
using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
namespace PacLib; namespace PacLib;
@ -50,7 +49,7 @@ public class PacHandler
_tcpListener = TcpListener.Create(_pacPort); _tcpListener = TcpListener.Create(_pacPort);
_isRunning = true; _isRunning = true;
_tcpListener.Start(); _tcpListener.Start();
Task.Factory.StartNew(() => Task.Factory.StartNew(async () =>
{ {
while (_isRunning) while (_isRunning)
{ {
@ -58,25 +57,25 @@ public class PacHandler
{ {
if (!_tcpListener.Pending()) if (!_tcpListener.Pending())
{ {
Thread.Sleep(10); await Task.Delay(10);
continue; continue;
} }
var client = _tcpListener.AcceptTcpClient(); var client = _tcpListener.AcceptTcpClient();
Task.Run(() => await Task.Run(() =>
{ {
var stream = client.GetStream(); var stream = client.GetStream();
var sb = new StringBuilder(); var sb = new StringBuilder();
sb.AppendLine("HTTP/1.0 200 OK"); sb.AppendLine("HTTP/1.0 200 OK");
sb.AppendLine("Content-type:application/x-ns-proxy-autoconfig"); sb.AppendLine("Content-type:application/x-ns-proxy-autoconfig");
sb.AppendLine("Connection:close"); sb.AppendLine("Connection:close");
sb.AppendLine("Content-Length:" + Encoding.UTF8.GetByteCount(_pacText)); sb.AppendLine("Content-Length:" + Encoding.UTF8.GetByteCount(_pacText));
sb.AppendLine(); sb.AppendLine();
sb.Append(_pacText); sb.Append(_pacText);
var content = Encoding.UTF8.GetBytes(sb.ToString()); var content = Encoding.UTF8.GetBytes(sb.ToString());
stream.Write(content, 0, content.Length); stream.Write(content, 0, content.Length);
stream.Flush(); stream.Flush();
}); });
} }
catch (Exception e) catch (Exception e)
{ {