自己写的 ring buffer 模板类

肯定没有boost 的ringbuf 写的好，但是可以在单片机编程中使用。单片机上没法使用boost，所以自己写一个，用在串口接收数据时。

template <class T>
class RingBuf
{
public:
    RingBuf(unsigned ringBufSize)
        : m_bufferSize(ringBufSize)
        ,   m_pBuffer(NULL)
        ,   m_head(0)
        ,   m_tail(0)
    {
        m_pBuffer = new T[ringBufSize];
    }
    ~RingBuf()
    {
        if (m_pBuffer != NULL)
        {
            delete[] m_pBuffer;
            m_pBuffer = NULL;
        }
    }
public:
    unsigned Count()
    {
        if (m_head < m_tail)
        {
            m_head = m_head % m_bufferSize;
            m_tail = m_tail % m_bufferSize;
        }
        unsigned head = m_head;
        unsigned tail = m_tail;
        if (head < tail)
        {
            return (tail - head + m_bufferSize);
        }
        else
        {
            return (head - tail);
        }
    }


    bool  IsFull()
    {
        return (Count() >= m_bufferSize);
    }
    bool  IsEmpty()
    {
        return (Count() == 0);
    }
    bool  Peek(T &value)
    {
        if (! Empty())
        {
            value = m_pBuffer[m_tail % m_bufferSize];
            return true;
        }
        return false;
    }
    bool  Pop(T &value)
    {
        if (! IsEmpty())
        {
            value = m_pBuffer[m_tail % m_bufferSize];
            m_tail ++;
            return true;
        }
        return false;
    }
    bool  Push(T value)
    {
        if (IsFull())
        {
            T popValue;
            Pop(popValue);
        }

        m_pBuffer[m_head % m_bufferSize] = value;
        m_head++;
        return true;
    }

    RingBuf &operator += (T value) {
        Push(value);
        return *this;
    }

    bool  PushString(T *pDataSource, unsigned pushLen)
    {
        for (int i=0; i<pushLen; i++)
        {
            Push(pDataSource[i]);
        }
        return true;
    }
    bool  PopString(T *pDataDest, unsigned popLen)
    {
        if (Count() < popLen)
        {
            return false;
        }

        for (int i=0; i<popLen; i++)
        {
            Pop(pDataDest[i]);
        }

        return true;
    }
    void  Flush()
    {
        m_head = m_tail;
    }

//==================================================================

//==================================================================

private:
    volatile unsigned  m_head;                 /* first byte of data */
    volatile unsigned  m_tail;                 /* last byte of data */
    T                                 *m_pBuffer;             /* block of memory or array of data */
    unsigned                    m_bufferSize;            /* leng}

这是部分代码，但是是全部的ring buf， 串口接收到数据时中断一次往里面 push 一个字节，然后判断添加点代码判断数据完整性等操作。