C#环形缓冲区(队列)完全实现

2019-12-30 13:31:39丽君

调用实例
生产


 int len = sConn.Receive(receiveBuffer, 0, receiveBuffer.Length, SocketFlags.None, out se);
if (len <= 0) throw new Exception("disconnect..");
if (len > 0)
{
  lock (LockReceiveBuffer)
  {
    while (len + receiveBufferManager.DataCount > MAX_BUFFER_LEN)    // 缓存溢出处理
    {
      Monitor.Wait(LockReceiveBuffer,10000);
    }
    receiveBufferManager.WriteBuffer(receiveBuffer, 0, len);
    Monitor.PulseAll(LockReceiveBuffer);
  }
} 

消费


 lock (LockReceiveBuffer)
{
  freame_byte = new byte[frameLen];
  receiveBufferManager.ReadBuffer(freame_byte, 0, frameLen);
  receiveBufferManager.Clear(frameLen);
} 

验证 
TCP大数据连续测试一周没出现问题内存问题。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持ASPKU。


注:相关教程知识阅读请移步到c#教程频道。