皮皮网

1.OC内存管理-runloop
2.Backtrader来啦：可视化篇（重构）
3.LiveDataBus

OC内存管理-runloop

        RunLoop 是通过内部维护的 事件循环( Event Loop )来对 事件/消息进行管理的一个对象。

        runloop 的官方文档在 thread 篇章 Run Loops ，也就从侧面说明了 runloop 是与线程息息相关的。

        官方有如下一张图：

        线程的输入源:

        线程针对输入源的处理机制：

        有以下案例：

        timer 与 performSelector 对应的回调都是 __CFRUNLOOP_IS_CALLING_OUT_TO_A_TIMER_CALLBACK_FUNCTION__ ：

        block 对应 __CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE0_PERFORM_FUNCTION__ ：

        主线程对应 __CFRUNLOOP_IS_SERVICING_THE_MAIN_DISPATCH_QUEUE__ :

        系统触摸事件对应 __CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE0_PERFORM_FUNCTION__ ：

        通知事件对应 __CFNOTIFICATIONCENTER_IS_CALLING_OUT_TO_AN_OBSERVER__ ：

        小结：

        滚动页面输出：

        页面滚动过程中处于 UITrackingRunLoopMode ，静止状态处于 kCFRunLoopDefaultMode 。

        输出：

        输出：

        既然 runloop 是一个事件循环，那么它与普通的循环有什么区别呢？

        普通循环：

        runloop 循环：

        那么可以得到以下结论：

        那么 runloop 是怎么做到的呢？

        通常我们会通过 NSRunLoop 去获取当前的 runloop ：

        定义如下：

        给 currentRunLoop 下符号断点：

        通过之前的分析已经定位到了 runloop 是在 CoreFoundation 中的 CoreFoundation源码 。正好 CoreFoundation 开源了 CFRunLoop ：

        那么核心逻辑就在 CFRunLoopRunSpecific 中。还有一个疑问是 runloop 可以休眠，那么它是如何实现的呢？

        要了解 runloop 的实现原理，首先要清楚它的数据结构。

        CFRunLoopRunSpecific 的第一个参数是 CFRunLoopGetCurrent() ：

        _CFRunLoopGet0

        CFRunLoopRef 的定义如下：

        实际上底层它是 __CFRunLoop 类型：

        对于 timer 而言:

        显然它是要依赖 mode 的。

        CFRunLoopMode

        而一个 mode 下又对应多个 items(source0、source1、timers、observers) ，所以就有如下关系：

        既然有多种 mode ，那么都有哪些呢？

        源码中有如下定义：

        它们对应 Foundation 中的：

        我们都清楚在页面滚动的时候有一个 UITrackingRunLoopMode ：

        除了以上 3 种 mode 还有两个私有 mode ：

        当 RunLoop 运行在 Mode1 上时，是无法接受处理 Mode2 或 Mode3 上的 Source、Timer、Observer 事件的。

        以 timer 为例，将 timer 加入到 runloop 中：

        底层调用了 CFRunLoopAddTimer ：

        根据要加入的 mode 区分是 common mode 和非 common mode 将 timer 加入 mode 中。这个时候只是将 timer 加入了 mode 中，要执行肯定要调用 CFRunLoopRun ，最终要调用 CFRunLoopRunSpecific 。

        在 __CFRunLoopRun 中调用了 __CFRunLoopDoTimers ：

        找到 mode 中的所有 timer 然后调用 __CFRunLoopDoTimer 。

        CFRunLoopAddTimer -> CFRunLoopRunSpecific -> __CFRunLoopRun -> __CFRunLoopDoTimers -> __CFRunLoopDoTimer -> __CFRUNLOOP_IS_CALLING_OUT_TO_A_TIMER_CALLBACK_FUNCTION__ 。

        与 timer 相同 source 会调用 CFRunLoopAddSource ：

        CFRunLoopAddSource -> CFRunLoopRunSpecific -> __CFRunLoopRun -> __CFRunLoopDoSources0/__CFRunLoopDoSources1 -> __CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE0_PERFORM_FUNCTION__ /__CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE1_PERFORM_FUNCTION__

        同理 observer 会调用 CFRunLoopAddObserver 。

Backtrader来啦：可视化篇（重构）

       量化投资与机器学习公众号为全网读者带来的Backtrader系列，深受欢迎，我们致力于提供免费、最清晰的Bt教程。QIML官方Github已上线，相关数据、商业模式源码代码一并同步，欢迎大家关注和星标。公众号希望为国内量化投资圈贡献一份力量，影响更多人了解和学习量化投资，找到适合自己的道路。如需分享内容，欢迎在评论区留言。treegrid 源码

       今天的《可视化篇》将介绍Backtrader观测器模块observers与自带的绘图函数plot()。我们将通过修改图形样式，基于回测返回的收益序列TimeReturn，结合pyfolio和matplotlib工具，自定义可视化图形。获取完整代码+数据，见文末链接。

       observers模块用于统计回测信息，并在plot()的帮助下实现可视化展示。最常用的观测器包括：

       - Broker观测器：记录经纪商中各时间点的可用资金和总资产。可视化时，会同时展示cash和values曲线，rocksdb源码若需单独展示，可分别使用Cash和Value观测器。

       - BuySell观测器：记录回测过程中的买入和卖出信号。可视化时，会在价格曲线上标注买卖点。

       - Trades观测器：记录回测过程中每次交易的盈亏。可视化时，会绘制盈亏点。

       - TimeReturn观测器：记录回测过程中的收益序列。可视化时，会绘制收益曲线。

       - DrawDown观测器：记录回测过程的sttuts源码回撤序列。可视化时，绘制回撤曲线。

       - Benchmark观测器：记录业绩基准的收益序列，必须事先通过数据添加函数添加至大脑cerebro中。可视化时，同时绘制策略本身的收益序列和业绩基准的收益曲线。

       如何添加观测器？observers通过addobserver()添加给大脑cerebro，参数obscls对应观测器类，args和kwargs对应观测器支持的设置参数。

       如何读取观测器数据？观测器属于lines对象，可以通过self.stats对象在Strategy中读取数据。观测器的ydye源码数据在所有指标计算完后、执行Strategy的next方法后运行并统计数据，因此读取的最新数据[0]相对与next的当前时刻晚一天。

       如何自定义观测器？自定义观测器遵循继承bt.observer.Observer类，指定要统计的数据为相应的line，随着回测进行依次存入数据。作为Lines对象的Observers和Indicator类，内部都有plotinfo和plotlines属性，用于回测结束后通过cerebro.plot()方法进行可视化展示。

       plot()图形绘制支持回测的三大内容：Data Feeds、Indicators和Observers。Data Feeds在回测开始前导入大脑，Indicators有的与Data Feeds一起绘制在主图上，有的以子图形式绘制，Observers通常绘制在子图上。

       plot()中的参数用于系统性配置图形，如修改图形样式、主题颜色等。若需系统性修改图形样式，可以重新定义PlotScheme类，或直接在plot()中修改参数。关于主题颜色，Backtrader提供多种主题色，可通过复制源码中定义的颜色并结合tab_index进行修改。

       局部绘图参数设置通过类内部的plotinfo和plotlines属性控制，plotinfo主要对图形整体布局进行设置，plotlines主要对具体line的样式进行设置。

       基于收益序列进行可视化，Backtrader自带的绘图工具方便实用。此外，结合pyfolio和matplotlib，根据回测返回的分析器TimeReturn、pyfolio、matplotlib可以得到可视化图形。不同主题下绘制效果也有所不同。

       关于回测结果的可视化，需求不同对应不同的可视化内容。Backtrader回测框架提供了友好的绘图接口，对于额外数据，可结合Backtrader分析器Analyzers返回的指标，选用Python绘图工具如Matplotlib、Seaborn、Plotly等进行可视化展示。

       量化投资与机器学习微信公众号专注于量化投资、对冲基金、Fintech、人工智能、大数据等领域，是业内主流自媒体，拥有来自公募、私募、券商、期货、银行、保险、高校等行业W+关注者，曾荣获AMMA优秀品牌力、优秀洞察力大奖，连续4年被腾讯云+社区评选为“年度最佳作者”。公众号致力于提供专业、全面的内容，帮助读者深入学习量化投资知识和技能。

LiveDataBus

        LiveDataBus是基于LiveData实现的类似EventBus的消息通信框架，它是基于LiveData实现的，完全可以代替EventBus，RxBus；

        LiveDataBus的主要是基于发布订阅设计模式，发布订阅模式定义了一种 “一对多” 的关系，和观察者模式是完全不同的两个设计模式；

        下面详细介绍核心类LiveData

        LiveData是一个可以被观察的数据holder，并且可以自动感知控件的生命周期，不会发生内存泄漏；

        LiveData需要一个观察者对象，当LiveData的值发生改变时，观察者会察觉到这个改变；

        使用livedata注册观察者监听

        使用livedata发送消息给观察者

        LiveData其实就是一个存放数据的holder，类似ViewHolder的holder，存放在LiveData里的数据会拥有LiveData的特性；

        LiveData是Android Architecture Components的一个类；这个类是谷歌在Google I/O 发布一套帮助开发者解决Android架构设计的方案。这个类有四个核心，后续会一一介绍；

        用第一代LiveDataBus订阅

        发送消息

        至于说他是第一代bus，说明肯定有问题，问题就是在post或者set一个value后，只要在一个frag/act里observe了，无论组件是否启动，都会收到value，即当在act1中post了，在act2中observe，但是post的时候act2没有运行，当启动act2，收到了value。收到了订阅前的消息

        通过查看LiveData的源码发现setValue（）开始，依次调用了

dispatchValue()-> considerNotify()-> observer.onChanged()

        postValue()会调用setValue（）所以同理；

        这就解释了为什么我们可以在observer中收到post来的value，为什么act2不运行也可以收到value；

        我们注意到当observer.mLastVersion >= mVersion的时候会直接return，不调用onChanged从而解决上面的问题。

        我们需要拿到mLastVersion，就需要拿到observer对象，顺着源码发现observer对象存在mObservers的map中；我们自定义一个mutableLiveData，改写他的observe（），在observe（）中，通过反射拿到mObservers对象，从而拿到observer.mLastVersion，将mVersion赋值给他；

        hook的作用相当于 在observe（）调用后执行observer.mLastVersion = mVersion; 让considerNotify（）直接return，可是我们如何收到订阅后的post呢？因为只有订阅的时候才会hook，在hook后，我们调用post（），会mVersion++，所以在判断 if (observer.mLastVersion >= mVersion) 的时候就又会是false了；