流水线上的思考——异步程序开发模型(3)

流水线上的思考——异步程序开发模型(3)

大家好,又见面了,我是全栈君。

上次我们讨论了关于业务之间无关联性的一种处理模式。但是对于很多的系统来说,这种无关性的处理方式是很少的,更多的恰恰是那些彼此之间存在一定联系的业务。例如:在网吧上网的玩家,一般来说他们会先进行上机,然后才下机。很少听说这个玩家还没有上机就需要下机的情况(如果有的话有可能这个系统有问题,或者出现了一些其它的原因)。 
这样的业务就存在一定的关联性,在我们系统处理过程中,势必要遵从他们的业务处理逻辑来进行处理,即业务中处理也需要一定的顺序性。
 
对于这种具有顺序性的业务,能否利用我们之前所使用的方法来进行处理呢?下面我们来简单地分析一下。
首先,我们之前讨论的处理模式,是在接收到业务数据以后,将这些业务数据直接投递给一个IOCP
的线程池来进行处理。这里我们会发现一个问题:当我们将业务1
发送给一个IOCP
线程池中的一个线程A
以后,再投递第二个业务2
时,业务处理是否为顺序的呢?如果是顺序的,那么我们就可以继续使用这种处理方式;但如果不是顺序的,那么我们肯定不能再使用这种方法。
很不幸,根据《windows
核心编程(第五版)》中所讲和本人亲身测试,对于IOCP
线程池的处理并不是顺序处理的。这就意味着我们需要重新构思一个方式来进行处理。
 
这种问题,估计每个人都有自己的处理方法,我在这里讲的处理方法仅是抛砖引玉。
我采用的是对象和线程管理的处理方法。就上面具的例子来说,就是每个网吧和一个线程进行绑定的方法。这样一来,针对每个网吧的业务数据来看,他的处理必然是顺序的,即处理完业务1
后再处理业务2
 
处理过程如下图:
流水线上的思考——异步程序开发模型(3)
 
可以看到业务从IOCP
网络线程中接收到以后,需要针对此业务属于哪个对象进行区分。然后从这个对象中得到处理该对象的线程。并将这个业务投递给这个线程进行处理。
 
今天我们讨论了对于业务具有顺序性的数据如何进行处理的方法。并且提出了一种解决的参考方法。这种方法不一定完全适合于您,如果您知道更好的方法请您留言。
 
通过这三篇文章,我们从一个流水线工作方式为入口,粗略讨论了在软件开发方面如何做到类似流水线这种开发模型。其中必然存在一些不足的地方,还请大家指出,谢谢。
本文转自狗窝博客51CTO博客,原文链接http://blog.51cto.com/fxh7622/1152176如需转载请自行联系原作者

fxh7622

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/108057.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • CTK Plugin Framework 基本原理

    CTK Plugin Framework 基本原理“CTKPluginFramework技术是面向C++的动态模型系统。该系统允许插件之间的松散耦合,并且提供了设计良好的方式来进行功能和数据…

    2022年5月25日
    30
  • 【云原生 • Docker】mysql、tomcat、nginx、redis 环境部署

    【云原生 • Docker】mysql、tomcat、nginx、redis 环境部署Docker下MySQL、tomcat、nginx、redis应用的搭建方式,附详细步骤与软件下载地址。

    2025年7月9日
    4
  • C语言游戏 双缓存解决闪屏问题 详细总结[通俗易懂]

    最近,应学校课程要求,要完成一个C语言课程设计。可以是写一个小游戏,或是写管理系统等。所以,准备做一个改版贪吃蛇:消灭小虫虫(瞎起的名字:D)。之前学过Java,所以学C语言也就比较顺利。而在刚学完C语言刚着手准备做C语言的小游戏时,却发现了一个问题——闪屏。(我在网上查找了很多关于双缓存,有关的解答很少,更少能够让一个完全不了解的小白一个明白的解释。下面我想和大家分享我使用…

    2022年4月10日
    98
  • 对 FLAG_ACTIVITY_NEW_TASK、FLAG_ACTIVITY_CLEAR_TOP、FLAG_ACTIVITY_SINGLE_TOP 的理解

    对 FLAG_ACTIVITY_NEW_TASK、FLAG_ACTIVITY_CLEAR_TOP、FLAG_ACTIVITY_SINGLE_TOP 的理解为了看得更清晰,以下使用代称newtask:FLAG_ACTIVITY_NEW_TASKcleartop:FLAG_ACTIVITY_CLEAR_TOPsingletop:FLAG_ACTIVITY_SINGLE_TOP文章目录default单独singletop单独cleartopcleartop+singletopnewtask单独newtasknewtask+sin…

    2022年7月17日
    17
  • finsh初步

    finsh初步一.finsh在RT-Thread中被设计成一个独立的线程,它试图从外部设备中获得用户的输入,然后对用户命令进行解析执行。正确使用finsh需要一个关联过程:rt_hw_board_init()函数调用串口初始化函数rt_hw_usart_init(),此函数初始化串口,并向系统注册“usart1”设备,接着系统调用rt_console_set_device()函数设置“usart1…

    2022年5月11日
    78
  • 全局平均池化(Global Average Pooling)

    出处:LinM,ChenQ,YanS.Networkinnetwork[J].arXivpreprintarXiv:1312.4400,2013.定义:将特征图所有像素值相加求平局,得到一个数值,即用该数值表示对应特征图。目的:替代全连接层效果:减少参数数量,减少计算量,减少过拟合思路:如下图所示。假设最终分成10类,则最后卷积层应该包含10个滤波器(即输…

    2022年4月6日
    65

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号