实现多线程对队列的读写操作(封装类)
#include "thread_base.h"
class CChildThread:public CThreadBase
{
protected:
virtual int Process(StructSyncData * oneData,void* args)
{
//printf("%lld\n",oneData->ID);
return 0;
}
virtual int init(char* cfgFileName)
{
m_ThreadNum=100;
m_BoolWriteBill=true;
return 0;
}
virtual void AfterAddData(long long popID,int iTime,int preRet)
{
if(preRet)
{
int t_Time=time(NULL);
WriteBill("[%lld][%d][%d]\n",popID,iTime,t_Time);
}
}
};
int main()
{
CChildThread t_thread;
int ret;
ret = t_thread.Init(NULL);
if(ret)
{
return 0;
}
t_thread.Start();
long long popID=0;
int i=0;
while(1)
{
StructSyncData *t_data = new StructSyncData();
t_data->ID=i;
t_thread.AddData(t_data,popID);
i++;
}
}
希望对大家有用~
版权所有,转载请注明出处.http://www.vimer.cn
原创文章,版权所有。转载请注明:转载自Vimer的程序世界 [ http://www.vimer.cn ]
本文链接地址: http://www.vimer.cn/?p=719
经典的消费者生产者模型
[回复]
Dante 回复:
十二月 31st, 2009 at 3:00 下午
呵呵,是啊,完善了统计和错误流水,这样功能会比较全面一些。
[回复]