我正在使用異步回調的 Windows 套接字應用程序。如果我使用 Thread 來啟動_StartListening，當我調用時StopListening，循環仍然停止在allDone.WaitOne().?但Task版本就可以了。有什么不同？我的代碼是這個的修改版本原始版本有felix-bManualResetEvent提到的競爭條件。我把它改成了，但問題仍然存在。SemaphoreSlim我在調試模式下嘗試過，即使我不啟動客戶端，if (cancelToken.IsCancellationRequested)在我調用后似乎也不會遇到斷點。StopListening對不起。我發現我不小心啟動了兩個socket服務器。那就是問題所在。?class WinSocketServer:IDisposable? {? ? ? ? public SemaphoreSlim semaphore = new SemaphoreSlim(0);? ? ? ? private CancellationTokenSource cancelSource = new CancellationTokenSource();? ? ? ? public void AcceptCallback(IAsyncResult ar)? ? ? ? {? ? ? ? ? ? semaphore.Release();? ? ? ? ? ? //Do something? ? ? ? }? ? ? ? private void _StartListening(CancellationToken cancelToken)? ? ? ? {? ? ? ? ? ? try? ? ? ? ? ? {? ? ? ? ? ? ? ? while (true)? ? ? ? ? ? ? ? {? ? ? ? ? ? ? ? ? ? if (cancelToken.IsCancellationRequested)? ? ? ? ? ? ? ? ? ? ? ? break;? ? ? ? ? ? ? ? ? ? Console.WriteLine("Waiting for a connection...");? ? ? ? ? ? ? ? ? ? listener.BeginAccept(new AsyncCallback(AcceptCallback),listener);? ? ? ? ? ? ? ? ? ? semaphore.Wait();? ? ? ? ? ? ? ? }? ? ? ? ? ? }? ? ? ? ? ? catch (Exception e)? ? ? ? ? ? {? ? ? ? ? ? ? ? Console.WriteLine(e.ToString());? ? ? ? ? ? }? ? ? ? ? ? Console.WriteLine("Complete");? ? ? ? }? ? ? ? public void StartListening()? ? ? ? {? ? ? ? ? ? Task.Run(() => _StartListening(cancelSource.Token));//OK? ? ? ? ? ? var t = new Thread(() => _StartListening(cancelSource.Token));? ? ? ? ? ? t.Start();//Can't be stopped by calling StopListening? ? ? ? }? ? ? ? public void StopListening()? ? ? ? {? ? ? ? ? ? listener.Close();? ? ? ? ? ? cancelSource.Cancel();? ? ? ? ? ? semaphore.Release();? ? ? ? }? ? ? ? public void Dispose()? ? ? ? {? ? ? ? ? ? StopListening();? ? ? ? ? ? cancelSource.Dispose();? ? ? ? ? ? semaphore.Dispose();? ? ? ? }? ? }
1 回答
慕哥9229398
TA貢獻1877條經驗 獲得超6個贊
您的代碼存在競爭條件，可能會導致死鎖（有時）。讓我們將線程命名為“監聽器”（運行的線程_StartListening）和“控制”（運行的線程StopListening）：
偵聽器線程：
if (cancelToken.IsCancellationRequested)-> false控制線程：
cancelSource.Cancel()控制線程：
allDone.Set()偵聽器線程：
allDone.Reset()-> 意外重置停止請求！監聽線程：
listener.BeginAccept(...)控制線程：
stopListening()退出，而監聽器繼續工作！偵聽器線程：
allDone.WaitOne()-> 死鎖！沒有人會這么做allDone.Set()。
問題在于如何使用該allDone事件，應該是相反的：應該在它因任何原因退出之前_StartListening執行，而應該執行：allDone.Set()StopListeningallDone.WaitOne()
class WinSocketServer:IDisposable
{
// I guess this was in your code, necessary to show proper stopping
private Socket listener = new Socket(......);
public ManualResetEvent allDone = new ManualResetEvent(false);
private CancellationTokenSource cancelSource = new CancellationTokenSource();
private void _StartListening(CancellationToken cancelToken)
{
try
{
listener.Listen(...); // I guess
allDone.Reset(); // reset once before starting the loop
while (!cancelToken.IsCancellationRequested)
{
Console.WriteLine("Waiting for a connection...");
listener.BeginAccept(new AsyncCallback(AcceptCallback),listener);
}
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
allDone.Set(); // notify that the listener is exiting
Console.WriteLine("Complete");
}
public void StartListening()
{
Task.Run(() => _StartListening(cancelSource.Token));
}
public void StopListening()
{
// notify the listener it should exit
cancelSource.Cancel();
// cancel possibly pending BeginAccept
listener.Close();
// wait until the listener notifies that it's actually exiting
allDone.WaitOne();
}
public void Dispose()
{
StopListening();
cancelSource.Dispose();
allDone.Dispose();
}
}
更新
值得注意的是，listener.BeginAccept直到有新的客戶端連接才會返回。停止監聽時，需要關閉socket( listener.Close())才能強制BeginAccept退出。
線程/任務行為的差異確實很奇怪，它可能源于任務線程是后臺線程，而常規線程是前臺線程。
- 1 回答
- 0 關注
- 111 瀏覽
添加回答
舉報
0/150
提交
取消