/**///////////////////////////////////////
// CStreamPacket by 太子 2005-12-13 //
/**///////////////////////////////////////#pragma once
const c_BufferBlockSize=0x10000;
class CStreamPacket
{
private:
unsigned char*m_pBuffer;
size_t m_BufferLength;
size_t m_DataStart;
size_t m_DataSize;
public:
CStreamPacket() : m_BufferLength(0), m_DataStart(0), m_DataSize(0)
{
m_pBuffer=new unsigned char[c_BufferBlockSize];
m_BufferLength=c_BufferBlockSize;
}
~CStreamPacket(){ delete[]m_pBuffer; }
private:
bool ResizeBuffer()
{
size_t size=m_BufferLength<<1;
unsigned char*tmp=new unsigned char[size];
unsigned char*tmp2;
memcpy(tmp,m_pBuffer+m_DataStart,m_DataSize);
tmp2=m_pBuffer;
m_pBuffer=tmp;
delete[]tmp2;
m_DataStart=0;
m_BufferLength=size;
return true;
}
bool RecomposeBuffer()
{
if(m_DataStart>0)
{
memcpy(m_pBuffer,m_pBuffer+m_DataStart,m_DataSize);
m_DataStart=0;
return true;
}
return false;
}
public:
// 從緩沖中取一個(gè)變量
// 可以是基本數(shù)據(jù)類型 也可以是struct
// 但不能為數(shù)組 否則不能正常取值
template <class T> CStreamPacket& operator>>( T& Data )
{
size_t Size=sizeof(T);
Data=*((T*)(m_pBuffer+m_DataStart));
m_DataStart+=Size;
m_DataSize-=Size;
return *this;
}
// 從緩沖中取一個(gè)0結(jié)尾數(shù)組
// 如C字符串
template <class T> CStreamPacket& operator>>( T Data[] )
{
size_t Size=sizeof(T);
size_t i=0;
while(true)
{
operator >>(Data[i]);
if(Data[i]==(T)0)break;
i++;
}
return *this;
}
// 向緩沖中存一個(gè)變量
template <class T> CStreamPacket& operator<<( const T& Data )
{
size_t Size=sizeof(T);
while(m_DataSize+m_DataStart+Size>m_BufferLength)//不能直接內(nèi)存copy
{
if(m_DataSize+Size>m_BufferLength)//緩沖大小不夠
{
ResizeBuffer();//擴(kuò)大
}
else
{
RecomposeBuffer();//重組
}
}
*((T*)(m_pBuffer+m_DataStart+m_DataSize))=Data;
m_DataSize+=Size;
return *this;
}
// 向緩沖中存一個(gè)0結(jié)尾的數(shù)組
// 如C字符串
template <class T> CStreamPacket& operator<<( T Data[] )
{
size_t i=0;
while(true)
{
operator <<(Data[i]);
if(Data[i]==(T)0)break;
i++;
}
return *this;
}
//來自另外一個(gè)CStreamPacket
CStreamPacket& operator<<( const CStreamPacket& Packet )
{
size_t Size=Packet.m_DataSize;
while(m_DataSize+m_DataStart+Size>m_BufferLength)//不能直接內(nèi)存copy
{
if(m_DataSize+Size>m_BufferLength)//緩沖大小不夠
{
ResizeBuffer();//擴(kuò)大
}
else
{
RecomposeBuffer();//重組
}
}
memcpy(m_pBuffer+m_DataStart+m_DataSize,Packet.m_pBuffer+Packet.m_DataStart,Packet.m_DataSize);
m_DataSize+=Size;
return *this;
}
size_t GetSize()
{
return m_DataSize;
}
void* GetBuffer()
{
return m_pBuffer+m_DataStart;
}
};// BUFFER.cpp : 定義控制臺應(yīng)用程序的入口點(diǎn)。
//
#include "stdafx.h"
#include ".\buffer.h"
#include <windows.h>
using namespace std;
struct testStruct
{
char name[10];
long age;
float ff;
bool sex;
};
int _tmain(int argc, _TCHAR* argv[])
{
//CBuffer buf1;
//buf1<<"Hello World!"<<L"我是中國人!!";
//buf1<<"1234567890";
//buf1<<(unsigned char)0x12;
//buf1<<(unsigned short)0x5634;
//buf1<<(unsigned long)0x34129078;
//testStruct ss;
//strcpy(ss.name,"ss.name");
//ss.age=0x86AE;
//ss.ff=3.;
//ss.sex=true;
//buf1<<ss;
//CBuffer buf2;
//long double ll,jj=3.141592653589793;
//long xx,yy=123456789;
//buf2<<jj;
//buf2<<yy;
//buf2>>ll;
//buf2>>xx;
CStreamPacket buf3;
#define MB_COUNT (0x100000)
#define MB_SIZE (0x400)
char*pp=new char[MB_SIZE];
char*pp2=new char[MB_SIZE];
memset(pp,'#',MB_SIZE);
pp[MB_SIZE-1]=(char)0;
DWORD t1,t2;
cout<<"塊大小"<<MB_SIZE<<"，測試次數(shù)"<<MB_COUNT<<endl;;
cout<<"開始...";
t1=GetTickCount();
for(int ii=0;ii<MB_COUNT;ii++)
{
buf3<<pp;
//cout<<"buf3.GetSize()="<<buf3.GetSize()<<endl;
buf3>>pp2;
//cout<<"buf3.GetSize()="<<buf3.GetSize()<<endl;
}
t2=GetTickCount()-t1;
cout<<"完成!"<<endl;
buf3<<pp;
cout<<(char*)buf3.GetBuffer()<<endl;
delete[]pp;
delete[]pp2;
//cout<<t2<<endl;
//cout<<(MB_SIZE*MB_COUNT)/(t2)<<" byte/ms"<<endl;
cout<<"處理"<<MB_SIZE*MB_COUNT<<"字節(jié),耗時(shí)"<<t2<<"毫秒！速度"<<(MB_SIZE*MB_COUNT)/(t2)<<"字節(jié)每毫秒"<<endl;
system("pause");
return 0;
}
posted on 2007-04-23 23:44
shaker(太子) 閱讀(1903)
評論(3) 編輯 收藏 引用 所屬分類:
C++