双缓存静态循环队列（三）

// TwoBufQueue.h: interface for the CTwoBufQueue class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_TWOBUFQUEUE_H__EA19608F_9562_4803_95C4_5C4A574CC928__INCLUDED_)
#define AFX_TWOBUFQUEUE_H__EA19608F_9562_4803_95C4_5C4A574CC928__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000
#include "BufQueue.h"

// 双缓存队列，减少读写操作的互斥碰撞，向无锁算法靠近，乒乓存储原理

/* 
1)对于读写双方读写操作你比较频繁，双方的的瞬时吞吐量存在差异，可以很好的利用缓存空间特性提读写效率。

2)消费数据的速度总是大于生产数据的的速度，本数据结构与单缓存队列无异。

3)可以减少了读写互斥消耗，同时读，同时写互斥仍存在。
*/

class CTwoBufQueue  
{
public:
    int GetdataSize();
    int Write(const char *pBuf, int writeBytes);
    int Read(char *pBuf, int readBytes);
    CTwoBufQueue();
    virtual ~CTwoBufQueue();
private:
    void private_SwitchPointer();
    CBufQueue m_Queue_A;
    CBufQueue m_Queue_B;
    CBufQueue *m_pRead_Q;
    CBufQueue *m_pWrite_Q;
    CCritcalS m_critcal;
};

#endif // !defined(AFX_TWOBUFQUEUE_H__EA19608F_9562_4803_95C4_5C4A574CC928__INCLUDED_)

// TwoBufQueue.cpp: implementation of the CTwoBufQueue class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "OverlapRoutine.h"
#include "TwoBufQueue.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CTwoBufQueue::CTwoBufQueue()
{
     this->m_pRead_Q = &m_Queue_A;
     this->m_pWrite_Q = &m_Queue_B;
}

CTwoBufQueue::~CTwoBufQueue()
{

}

// 交换缓存对象指针
void CTwoBufQueue::private_SwitchPointer()
{
    CBufQueue *pTemp = this->m_pRead_Q;
    this->m_pRead_Q = this->m_pWrite_Q;
    this->m_pWrite_Q = pTemp;
}

int CTwoBufQueue::Read(char *pBuf, int readBytes)
{
    int res = this->m_pRead_Q->Read(pBuf,readBytes);
    if(res>0)
    {
        return res;
    }else //读缓存空 ，交换缓存对象指针
    {
        this->m_critcal.Lock();
        this->private_SwitchPointer();
        this->m_critcal.Free();

        return this->m_pRead_Q->Read(pBuf,readBytes);
    }
}

// 写操作指针对当前buf对象,不做交换
int CTwoBufQueue::Write(const char *pBuf, int writeBytes)
{
    this->m_critcal.Lock();
    int res = this->m_pWrite_Q->Write(pBuf,writeBytes);
    this->m_critcal.Free();

    return res;
}

int CTwoBufQueue::GetdataSize()
{
    return this->m_pRead_Q->GetdataSize()+this->m_pWrite_Q->GetdataSize();
}