#include?
#include?
#include?

#include?“NonLockingBuffer.h“

#define??PORT_NUMBER?9998

#define?GROUP_ITEM_COUNT?128
#define?THREAD_RUN_LOOP_TIMES?60
#define?MAX_THREAD_COUNT_NUMBER?40


class?CThreadTime
{
public:????
????void????BeginGetElapsedTime（）;
????__int64?EndGetElapsedTime（）;

private:
????__int64?FileTimeToQuadWord（PFILETIME?pft）;

private:
????FILETIME?ftKernelTimeStart;
????FILETIME?ftKernelTimeEnd;
????FILETIME?ftUserTimeStart;
????FILETIME?ftUserTimeEnd;
????FILETIME?ftDummy;
};

//?Get?the?time?elapsed?since?the?thread?start
inline?void?CThreadTime::BeginGetElapsedTime（）
{
????GetThreadTimes（GetCurrentThread（）?&ftDummy?&ftDummy?&ftKernelTimeStart?&ftUserTimeStart）;
}

//?Calculate?the?time?elapsed?
inline?__int64?CThreadTime::EndGetElapsedTime（）
{
????GetThreadTimes（GetCurrentThread（）?&ftDummy?&ftDummy?&ftKernelTimeEnd?&ftUserTimeEnd）;

????__int64?qwKernelTimeElapsed?=?FileTimeToQuadWord（&ftKernelTimeEnd）?-?FileTimeToQuadWord（&ftKernelTimeStart）;
????__int64?qwUserTimeElapsed?=?FileTimeToQuadWord（&ftUserTimeEnd）?-?FileTimeToQuadWord（&ftUserTimeStart）;

????//?Get?total?time?duration?by?adding?the?kernel?and?user?times.
????//?the?default?is?100ns?so?we?convert?it?to?ms
????//return?（qwKernelTimeElapsed?+?qwUserTimeElapsed）?/?10000;

????return?（qwKernelTimeElapsed?+?qwUserTimeElapsed）?/?10;
}

inline?__int64?CThreadTime::FileTimeToQuadWord（PFILETIME?pft）?
{
????return?（Int64ShllMod32（pft->dwHighDateTime?32）?|?pft->dwLowDateTime）;
}


class?CStopwatch?
{
public:
????CStopwatch（）?
????{?
????????QueryPerformanceFrequency（&m_liPerfFreq）;
????????Start（）;
????}

????void?Start（）?
????{?
????????QueryPerformanceCounter（&m_liPerfStart）;
????}

????__int64?Now（）?const?
????{
????????//Returns?#?of?milliseconds?since
????????//Start?was?called

????????LARGE_INTEGER?liPerfNow;
????????QueryPerformanceCounter（&liPerfNow）;

????????return?（（（liPerfNow.QuadPart?-?
????????????m_liPerfStart.QuadPart）?*?1000）/
????????????m_liPerfFreq.QuadPart）;
????}

private:

????//Counts?per?second
????LARGE_INTEGER?m_liPerfFreq;???

????//Starting?count
????LARGE_INTEGER?m_liPerfStart;??
};

//?2
//CThreadTime?ElapsedTime;
//ElapsedTime.BeginGetElapsedTime（）;

//?4
//CStopwatch?spWatch;

//?do?................

//2
//int?iElapse?=?ElapsedTime.EndGetElapsedTime（）;

//4
//__int64?iElapse?=?spWatch.Now（）;


class?WriteLogToFile
{
public:
????WriteLogToFile（）
????????:?outfile（“d:\\log\\log.txt“?std::ofstream::binary?|?std::ofstream::app）
????{

????}

????virtual?void?Handle（Item*?entry）
????{
????????outfile.write?（entry->GetItemPointer（）?entry->GetDataLen（））;
????????outfile.flush（）;
????????entry->SetDataSign（false）;

????????//printf（“entry?size?%d\n“entry->Size（））;
????}

????~WriteLogToFile（）
????{
????????outfile.close（）;
????}
private:
????std::ofstream?outfile;
};

class?