欢迎访问皮皮网官网
皮皮网

【链我巴巴源码】【风云源码】【rip源码】observers源码

时间:2024-11-19 08:33:25 分类:休闲 来源:isulad源码

1.OC内存管理-runloop
2.Backtrader来啦:可视化篇(重构)
3.LiveDataBus

observers源码

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已上线,相关数据、链我巴巴源码代码一并同步,欢迎大家关注和星标。公众号希望为国内量化投资圈贡献一份力量,影响更多人了解和学习量化投资,找到适合自己的道路。如需分享内容,欢迎在评论区留言。风云源码

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

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

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

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

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

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

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

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

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

       如何读取观测器数据?观测器属于lines对象,可以通过self.stats对象在Strategy中读取数据。观测器的readelf源码数据在所有指标计算完后、执行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了;

copyright © 2016 powered by 皮皮网   sitemap