继续一下源码的走读啊， 最近看了点别的源代码，发现自己好像一个不会写代码的孩子一样。。。。总觉得自己差了一点什么，但是又说不上来， 只能继续努力了。
继续上一个部分，
start方法
里面有个eventLoop, 估计是监听一堆事件的， command＋B ，看下JobSchedulerEvent有什么类型
Event类型
eventLoop内部
看到这里的第一反应是， 里面是用队列来做的，而且长度没限制， 当然也没法限制， 要是队列满了怎么办，是写到硬盘里吗，还是有别的方法？
看了一眼注释，
队列长度说明
扎心了，老铁。。。
process逻辑
代码还是挺清楚的，
两个部件
什么listener的逻辑就不看了，里面太绕， 看着闹心，看下重要的两个，
start
里面的receive方法
receive方法
里面的逻辑就不细看了， 就看两点吧， 一， 有多少个inputstream就有多少个receiver， 二呢，所有的receiver都在相应的executor上。
后面receiver的内容明天继续。
继续一下源码的走读啊， 最近看了点别的源代码，发现自己好像一个不会写代码的孩子一样。。。。总觉得自己差了一点什么，...
最近刚好有点时间， 也把Spark代码看了看，这个系列会一直更新下去，由于本人的scala功底也不是太强，这里权当...
走读内核源码，看看 epoll 的 LT 和 ET 模式区别。 详细信息可以参考文章《[epoll 源码走读] e...
TestNG框架源码走读一：入口TestNG框架源码走读二：测试套执行 上一篇测试套执行主要介绍了SuiteRun...
来源JTA-atomikos源码走读
Spark-Streaming Spark-Streaming，思维导图
TestNG框架源码走读一：入口 上一篇主要走读TestNG类的main函数入口，其中TestNG#runSuit...
文章主要对 tcp 通信进行 epoll 源码走读。 Linux 源码：Linux 5.7 版本。epoll 核心...
在走读beego的源码时，有如下操作。
Android存储系统源码走读（一）：StorageManagerService[https://juejin.c...
本文标题：Spark-streaming源码走读（一）
本文链接：https://www.haomeiwen.com/subject/eyguottx.html
网友评论