#include <QCoreApplication>
#include <c_mem.h>
#include "c_thread.h"
#include <string>
#include <iostream>
#include <QDebug>
#include <QLoggingCategory>
static void callback(s_mem *mem)
{
if(mem!=NULL)
{
std::string s((char*)mem->v_data,mem->v_len);
std::cout<<s<<std::endl;
}
}
int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);
QLoggingCategory::defaultCategory()->setEnabled(QtDebugMsg, true);
qDebug()<<"start main"<<endl;
QThread::sleep(2);
Controller ctrl(&a);
ctrl.start(callback);
for(int i = 0;i<10000;i++)
{
char buffer[128];
sprintf(buffer,"this is data %d",i);
ctrl.add_data((uint8_t*)buffer,strlen(buffer));
QThread::msleep(5);
// std::cout<<"push "<<i<<std::endl;
}
QThread::sleep(2);
for(int i = 10000;i<20000;i++)
{
char buffer[128];
sprintf(buffer,"this is data %d",i);
ctrl.add_data((uint8_t*)buffer,strlen(buffer));
QThread::msleep(5);
// std::cout<<"push "<<i<<std::endl;
}
QThread::sleep(2);
for(int i = 20000;i<30000;i++)
{
char buffer[128];
sprintf(buffer,"this is data %d",i);
ctrl.add_data((uint8_t*)buffer,strlen(buffer));
QThread::msleep(5);
// std::cout<<"push "<<i<<std::endl;
}
ctrl.stop();
qInfo()<<"here is over"<<endl;
return a.exec();
}
评论0