BufferManagerの現実的な使用例

Question

OutOfMemoryExceptionの底部に到達しようとしました.netのBufferManagersは、WCFのバッファされたTransferModeで使用され、文字通り何百メガバイトも無駄にしていました。詳細についてはHow can I prevent BufferManager/PooledBufferManager in my WCF client app from wasting memory?を参照してください。単に「バッファされた」から「ストリーミングされた」に切り替えるだけで問題を解決できます）。

BufferManagersは、通常必要とするときにバイト配列を割り当てるだけでなく、参照が範囲外になったらそれらをクリーンアップおよびリサイクルするためにGCに頼って、通常どおりに行うより優れた代替手段として発明されました。

だから私の質問です：実際のアプリケーションでBufferManagersを使用していた人は、バッファーマネージャーを手作業でClear（）しなければならないという不都合を正当化するために、 ？

もしそうなら、手動で1バイトのバッファを作成し、そのバッファへの参照を保持してその特定の問題を解決できなかったでしょうか？

Answer 1

私は最近、複数のクライアント接続（最大500の同時接続）を受け入れたプロキシサービスを開発しました。プロキシは、クライアント要求を宛先サーバーに中継し、応答を宛先サーバーからクライアントに中継しました。プロキシサービスは、バイト配列（Byte []）をバッファとして使用してデータを送受信しました。 Buffer Managerはありませんでした。

プロキシがソケットからデータを送受信するたびに、新しいバイト配列を作成していました。リソースモニターのプライベートバイトは増加し続けました。 ANT Memory Profilerツールを実行すると、大きな断片が増え続けました。

解決策は、Buffersによって使用されるメモリを管理するための単純なBuffermanagerクラスを実装することでした。ここにコードスニペットがあります

public class BufferManager 
    { 
     private readonly int m_ByteSize; 

     private readonly Stack<byte[]> m_Buffers; 
     private readonly object m_LockObject = new Object(); 

     #region constructors 

     public BufferManager(int _byteSize, int _poolCount) 
     { 
      lock (m_LockObject) 
      { 
       m_ByteSize = _byteSize; 
       m_Buffers = new Stack<Byte[]>(_poolCount); 
       for (int i = 0; i < _poolCount; i++) 
       { 
        CreateNewSegment(); 
       } 
      } 
     } 

     #endregion //constructors 

     public int AvailableBuffers 
     { 
      get { return m_Buffers.Count; } 
     } 


     public System.Int64 TotalBufferSizeInBytes 
     { 
      get { return m_Buffers.Count * m_ByteSize; } 
     } 

     public System.Int64 TotalBufferSizeInKBs 
     { 
      get { return (m_Buffers.Count * m_ByteSize/1000); } 
     } 

     public System.Int64 TotalBufferSizeInMBs 
     { 
      get { return (m_Buffers.Count * m_ByteSize/1000000); } 
     } 



     private void CreateNewSegment() 
     { 
      byte[] bytes = new byte[m_ByteSize]; 
      m_Buffers.Push(bytes); 
     } 



     /// <summary> 
     /// Checks out a buffer from the manager 
     /// </summary>   
     public Byte[] CheckOut() 
     { 
      lock (m_LockObject) 
      { 
       if (m_Buffers.Count == 0) 
       { 
        CreateNewSegment(); 

       } 
       return m_Buffers.Pop(); 
      } 
     } 


     /// <summary> 
     /// Returns a buffer to the control of the manager 
     /// </summary> 
     ///<remarks> 
     /// It is the client’s responsibility to return the buffer to the manger by 
     /// calling Checkin on the buffer 
     ///</remarks> 
     public void CheckIn(Byte[] _Buffer) 
     { 
      lock (m_LockObject) 
      { 
       m_Buffers.Push(_Buffer); 
      } 
     } 


    }