所以我正在為.System.Net.WebSockets.ClientWebSocket您如何看待我想出的以下方法，它是線程安全的嗎？重要的是，一次只執行 1 個線程，等待線程將按 FIFO 順序執行。_ws.SendAsync另一種解決方案是使用BlocklingCollection和生產者 - 消費者模式。但是 BlockingCollection 沒有異步等待功能，所以如果它是線程安全的，我更喜歡當前的解決方案。我也非常感謝其他建議。private ClientWebSocket _ws;private int _sendTicketCount = 0;private int _sendTicketCurrent = 1;public async Task SendAsync(string message){ if (_ws.State != WebSocketState.Open) throw new Exception("Connection is not open"); try { int mySendTicket = Interlocked.Increment(ref _sendTicketCount); if (mySendTicket != _sendTicketCurrent) { await Task.Run(() => SpinWait.SpinUntil(() => mySendTicket == _sendTicketCurrent)).ConfigureAwait(false); } var cancel = new CancellationTokenSource(5000); var bytes = new ArraySegment<byte>(Encoding.UTF8.GetBytes(message)); await _ws.SendAsync(bytes, WebSocketMessageType.Text, true, cancel.Token).ConfigureAwait(false); } catch(Exception ex) { throw ex; } finally { Interlocked.Increment(ref _sendTicketCurrent); }}
2 回答
炎炎設計
TA貢獻1808條經驗 獲得超4個贊
_sendTicketCurrent需要是易失性的，否則允許JIT將值緩存在寄存器中，這可能導致無限循環。除此之外，它看起來是線程安全的，除了這是對CPU的巨大浪費（SpinWait完全使用內核）。
另外，做真的沒有意義。無論如何，您都要持有一個線程，因此您可以在當前線程中執行等待。await Task.Run(() => SpinWait.SpinUntil(() => mySendTicket == _sendTicketCurrent))
為了以更優化的方式執行所需的操作，已經提供了一個開箱即用的異步兼容同步基元：SemaphoreSlim。
private SemaphoreSlim _semaphore = new SemaphoreSlim(1, 1);
public async Task SendAsync(string message)
{
if (_ws.State != WebSocketState.Open)
throw new Exception("Connection is not open");
try
{
await _semaphore.WaitAsync().ConfigureAwait(false);
var cancel = new CancellationTokenSource(5000);
var bytes = new ArraySegment<byte>(Encoding.UTF8.GetBytes(message));
await _ws.SendAsync(bytes, WebSocketMessageType.Text, true, cancel.Token).ConfigureAwait(false);
}
finally
{
_semaphore.Release();
}
}
- 2 回答
- 0 關注
- 150 瀏覽
添加回答
舉報
0/150
提交
取消