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

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

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

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

fxh7622

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

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

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • 孙鑫老师 java从入门到精通 视频教程 批量下载

    孙鑫老师 java从入门到精通 视频教程 批量下载本视频教程是孙鑫老师亲自开发录制的,内容涵盖了java技术从入门到精通整个过程。对于java爱好者是一套不可多得的教材!相信下载此教程的同志都是未来的电脑高手,对于批量下载的方法我在这时就不一一说了,相信兄弟们都能找到这种简单规律。这里以第三课批量下载为例简单说一下:(记得将通配符长度设为1哦)第一课Java的一些基本概念http://www.ibook8.com/te

  • 【CSS】CSS样式表+复合选择器

    【CSS】CSS样式表+复合选择器CSS样式表+复合选择器总结

  • 概率基础-随机试验-古典概型-几何概型「建议收藏」

    概率基础-随机试验-古典概型-几何概型「建议收藏」概率基础-随机试验-古典概型-几何概型

  • 遗传算法_aforge遗传算法

    遗传算法_aforge遗传算法一、遗传算法简介:遗传算法是进化算法的一部分,是一种通过模拟自然进化过程搜索最优解的方法。二、遗传算法思想:遗传算法组成:1.编码2.适应度函数3.遗传算子:选择、交叉、变异4.运行参数借鉴生物进化论,遗传算法将要解决的问题模拟成一个生物进化的过程,通过复制、交叉、突变等操作产生下一代的解,并逐步淘汰掉适应度函数值低的解,增加适应度函数值高的解。这样进化N代后就很有可能会进化出适应度函数值很高的个体。2.1.编码将问题的解编码称字符串形式才能使用遗传算法。最简单的一种编码是二进制编码,即

  • myBatis源码学习之SqlSessionFactory

    myBatis源码学习之SqlSessionFactory/***Createsan{@linkSqlSesion}outofaconnectionoraDataSource**@authorClintonBegin*///SqlSessionFactory接口,通过openSession方法获得SQLSessionpublicinterfaceSqlSessionFactory{SqlS

  • eureka 集群失败的原因_Eureka集群的那些坑

    eureka 集群失败的原因_Eureka集群的那些坑今天遇到一个Eureka集群的一个坑。问题现场类似是这样的:两台Eureka组成的服务注册中心集群,两台服务提供方server1、server2,两个服务调用方client1、client2。正常的情况下:client1和client2通过服务中心获取的服务提供方的注册的元数据信息,然后本地缓存调用server2、server1的服务API是没问题的。调用server的api服务时采用的Feign…

发表回复

您的电子邮箱地址不会被公开。

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