*免分资源链接点击打开链接http://download.csdn.net/detail/goldenhawking/4492378

有了TCP、线程池,我们就可以把他们连接起来。使用最简单的 QMainWindow吧,设计个UI,而后,创建我们的线程池、Service,并把TcpService 的数据接收信号与线程池的数据处理信号连接起来。

为了模拟处理任务,我们简单的设计一个转换大小写字符的函数作为处理过程的模拟,这样有利于在超级终端调试、模拟。

#ifndef MYTASKITEM_H
#define MYTASKITEM_H#include "qghthreadtaskitem.h"class MyTaskItem : public QGHThreadTaskItem
{Q_OBJECTpublic:MyTaskItem(QObject *parent);~MyTaskItem();public:virtual void run(QObject * task_source, const QByteArray & data_array);signals:void evt_SendData(QObject * objClient,const QByteArray & dtarray);
};#endif // MYTASKITEM_H

上述的类中的信号用来把处理结果发回生产者(也可以是别的消费者,取决于信号的连接)

void MyTaskItem::run(QObject * task_source, const QByteArray & data_array)
{QByteArray res;foreach (char c,data_array){res.push_back((c>='a'&& c<='z')?c+('A'-'a'):c);if (c==015)res.push_back(012);}emit evt_SendData(task_source,res);return ;
}

简单的大小写转换,以及为了超级终端设置的换行符格式转换。为了模拟吃力的运算时间,我们加上一个sleep

void MyTaskItem::run(QObject * task_source, const QByteArray & data_array)
{QByteArray res;foreach (char c,data_array){res.push_back((c>='a'&& c<='z')?c+('A'-'a'):c);if (c==015)res.push_back(012);}_sleep (50);emit evt_SendData(task_source,res);return ;
}

具体工程参见我的资源, _sleep 在资源中并没有加上。

上几个图,首先是服务端的配置,

设置端口、线程数、是否为每个客户端发来的数据包保持FIFO,以及发回消费者时载荷的大小。而后,启动,运行客户端连接

客户端是一个模拟程序,会模拟N个连接发送数据。当然,在XP下一个程序只许开10个连接。

------------------------------------------

对没有安装VC2010的Windows用户,可以用命令行编译,具体方法。

1、打开QT的命令行

进入文件夹,用命令编译服务端

而后编译客户端

生成的文件在 Debug 和 Release了

如果提示找不到QT的DLL,则可以设置系统路径到QT/BIN

QT 线程池 + TCP 小试(三)实现最终功能相关推荐

  1. QT 线程池 + TCP 小试(一)线程池的简单实现

     *免分资源链接点击打开链接http://download.csdn.net/detail/goldenhawking/4492378 很久以前做过ACE + MFC/QT 的中轻量级线程池应用, ...

  2. QT 线程池 + TCP 小试(二)实现通信功能

     *免分资源链接点击打开链接http://download.csdn.net/detail/goldenhawking/4492378 有了线程池,我们下一步就利用 QTcpServer 搭建一个 ...

  3. 线程池解析(三)——Worker源码解析

    相关文章 线程池解析(一)--概念总结 线程池解析(二)--execute.addWorker源码解析 线程池解析(三)--Worker源码解析 线程池解析(四)--submit源码解析(Runnab ...

  4. 聊一聊java线程池ThreadPoolExecutor(三)——线程池中是如何执行任务的?

    看到这个图片没?没错,就是一辆教练车!我,一个已经工作了好几年大龄暖男,最终还是走上了学车的道路!环顾周围,同事中几乎都手持驾照了. 早上挤出了一小时,练习科目二,前进,后退,前进,后退!最后小腿感觉 ...

  5. qt下编写linux消息队列,C++11消息队列 + Qt线程池 + QRunnable执行任务简单模型

    1.模板类queue,包含头文件中,是一个FIFO队列. queue.push():在队列尾巴增加数据 queue.pop():移除队列头部数据 queue.font():获取队列头部数据的引用 .. ...

  6. 聊聊并发(三)——JAVA线程池的分析和使用

    1. 引言 合理利用线程池能够带来三个好处.第一:降低资源消耗.通过重复利用已创建的线程降低线程创建和销毁造成的消耗.第二:提高响应速度.当任务到达时,任务可以不需要等到线程创建就能立即执行.第三:提 ...

  7. 面试官一个线程池问题把我问懵逼了。

    你好呀,我是why哥. 前几天,有个朋友在微信上找我.他问:why哥,在吗? 我说:发生肾么事了? 他啪的一下就提了一个问题啊,很快. 我大意了,随意瞅了一眼,这题不是很简单吗? 结果没想到里面还隐藏 ...

  8. Java线程池实现原理及其在美团业务中的实践

    来自:美团技术团队 随着计算机行业的飞速发展,摩尔定律逐渐失效,多核CPU成为主流.使用多线程并行计算逐渐成为开发人员提升服务器性能的基本武器.J.U.C提供的线程池ThreadPoolExecuto ...

  9. Java并发—线程池ThreadPoolExecutor基本总结

    原文作者:Matrix海子 原文地址:Java并发编程:线程池的使用 在前面的文章中,我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线 ...

最新文章

  1. wikioi 1083 Cantor表
  2. 统一沟通-技巧-7-Lync 2010-配置信息-EWS未部署-增加版
  3. java-并发-并发容器(3)
  4. Oracle 原理:数据装载 ,SQLldr ,外部表
  5. flask 实现异步非阻塞----gevent
  6. python基础-第六篇-6.2模块
  7. osea/Beat Classification 4.0-4.2
  8. 如何快速把英语单词导入有道词典
  9. html5 打开支付宝app,支付宝H5唤醒APP
  10. 彻底卸载VMware虚拟机的详细步骤
  11. shell 亚瑟王环
  12. Discuz!您当前的访问请求当中含有非法字符,已经被系统拒绝解决办法
  13. 【CSDN竞赛第四期】编程赛后总结与分享
  14. 人工智能:确定性推理
  15. STM32单片机使用W5500作为http server通过网页进行配参(一.使用VScode模拟试验)
  16. 聊一聊我们应该如何有效学习
  17. 数据库Navicat建表出现1064错误原因
  18. 基于SMS短信平台给手机发送短信
  19. 【Docker】7、数据卷详解:具名挂载、匿名挂载、初识DockerFile、数据卷容器
  20. Goahead嵌入式linux移植资料整理

热门文章

  1. 什么是安斯库姆四重奏?为什么统计分析之前必须要作图?
  2. 最新进展!单细胞数据显示ACE2在鼻腔、肾脏、睾丸均有分布!
  3. 聚类分析(三)Mini Batch KMeans算法
  4. AnyTrans使用教程:将照片从 Mac 传输到 iPhone 的方法
  5. 常用输入法隐藏的这些神奇功能
  6. Linux学习之后台运行进程
  7. 数字系统设计学习之VHDL输入设计
  8. selenium java封装_selenium2.0的初步封装(java版本)
  9. C++|Java混合实验-java搭建post方法靶场,Qt发送请求获取数据
  10. Qt工作笔记- 解决cc1plus.exe: error: out of memory allocating