首页  流程图  详情

statserver

2015-04-26 14:23:21   7  举报





为你推荐

查看更多



stat_report

StatServer是一款强大的统计分析软件，它能够帮助用户轻松处理各种复杂的数据问题。这款软件提供了丰富的统计方法和模型，包括描述性统计、回归分析、方差分析、聚类分析等，可以满足用户在科研、教育、商业等领域的数据分析需求。StatServer具有直观的用户界面和强大的数据处理能力，使得即使是没有统计背景的用户也能够快速上手。此外，StatServer还支持多种数据格式，包括CSV、Excel、SPSS等，方便用户导入和导出数据。总的来说，StatServer是一款实用且易用的统计分析工具，无论你是数据分析师还是学术研究者，都能在StatServer中找到你需要的功能。

作者其他创作

大纲/内容

sSql = \"insert ignore into \

StatDbManager::insert2Db

QueueItem：size_t _index; 【使用的db】string _date; 【插入的时间】string _tflag; 【分钟】NotifyEvent *_notify;

TC_ThreadQueue\t_queue;

向数据库插入数据的线程类ReapSSDProcThread

StatDbManager

NotifyEvent :int _run_times; 【需要处理的数据数目】TC_Atomic _atomic; 【原子计数】TC_ThreadLock\t_monitor;bool\t_flag; 【结束标志】

creatTable 看表是否存在，不存在则创建表

1. 根据_vAllStatMsg大小，设定此次入库的计数：_notifyItem-_atomic = 0;_notifyItem-_run_times = iSize;_notifyItem-_flag=false;2. 设置此次向数据库插入数据的线程类使用的对应数据库pItem = new QueueItem();pItem-_index = vDb[k];pItem-_date = sDate;pItem-_tflag = sFlag;pItem-_notify = _notifyItem;iInsertThreadIndex = StatDbManager::getInstance()-getDbToIpIndex(vDb[k]);_runners[iInsertThreadIndex]-put(pItem);

1. 根据数据分库数量大小N生成 N个想数据库插入数据的线程类 int iInsertDataNum = StatDbManager::getInstance()-getDbIpNum();for(int i = 0; i start(); _runners.push_back(r); }2. _vAllStatMsg 的大小设置和数据分库数量一致

循环等待：while(!_notifyItem-_flag && !bTimeout)1. TC_ThreadLock::Lock lock(_notifyItem-_monitor); _notifyItem-_monitor.timedWait(2000); 每次循环都会给2s的机会2. 超时设定： if(TNOW - iCurrent (g_app.getInserInterv() - 2) * 60)

线程池

g_hashmap数据定时入库的线程类ReapSSDThread