(十六) 试着使用RxJava

2023-12-19 07:58
文章标签 java 使用 十六 rx 试着

本文主要是介绍(十六) 试着使用RxJava,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前言: 看了RxJava的Readme和一些关于RxJava的博客,对RxJava有些简单地了解了,开始练个手熟悉一下,练手过程中发现由于RxJava版本迭代,参考博客中给的例子已经不能直接用了,说明这种第三方库的使用还是有风险的。


参考博客:给 Android 开发者的 RxJava 详解


基于RxJava版本:2.1.12


demo地址:点击打开链接



1. RxJava基础知识

RxJava正如Readme所述,“它扩展了观察者模式以支持数据/事件序列,并添加了运算符,使您可以从对低级线程,同步,线程安全性和并发数据结构等事物中抽身,改为可以声明性地组合序列

首先它是扩展了观察者模式。

观察者模式分为4个关键部分:

Observable (可观察者,即被观察者)、 Observer (观察者)、 subscribe (订阅)、事件。

RxJava的使用也和这4个关键部分分不开的,下面结合例子分析对应代码扮演的角色。


2. 结合例子看观察者模式(待修缮)

我参考前文提及博客的例子发现会报错,有些接口已经不能用了,所以瞎调用一通,反正按正常观察者模式写应该没错。

RxJava其实看例子就能很好地分清楚Observable和Observer,可以类比button.setOnClickListener(new OnClickListener())。

如上图所述Observale订阅了Observer,事件到来以后会回调Observer声明的的回调方法,不是很清楚RxJava中什么扮演了事件的角色,button例子中事件是指点击事件,当监控到点击事件后,就会回调onClick方法。

上面的例子执行结果如下:

如上所示貌似可以从例子中看到各API调用顺序,其实只有Observer的onSubscribe和ObservableOnSubscribe subscribe是确定的,onNext和onComplete不确定的,因为我写在了ObservableOnSubscribe subscribe中,按理说来onNext和onComplete是事件触发后会回调的,而不是即刻调用。所以这个例子有点问题。

当去掉ObservableOnSubscribe subscribe中调用onNext和onComplete后这两个方法就不被调用了。




3. 加上Schedulers的例子

----------参考begin(有删减)----------

在RxJava 中,Scheduler ——调度器,相当于线程控制器,RxJava 通过它来指定每一段代码应该运行在什么样的线程。RxJava 已经内置了几个 Scheduler ,它们已经适合大多数的使用场景:

  • Schedulers.newThread(): 总是启用新线程,并在新线程执行操作。
  • Schedulers.io(): I/O 操作(读写文件、读写数据库、网络信息交互等)所使用的 Scheduler。行为模式和 newThread() 差不多,区别在于 io() 的内部实现是是用一个无数量上限的线程池,可以重用空闲的线程,因此多数情况下 io()newThread() 更有效率。不要把计算工作放在 io() 中,可以避免创建不必要的线程。
  • Schedulers.computation(): 计算所使用的 Scheduler。这个计算指的是 CPU 密集型计算,即不会被 I/O 等操作限制性能的操作,例如图形的计算。这个 Scheduler 使用的固定的线程池,大小为 CPU 核数。不要把 I/O 操作放在 computation() 中,否则 I/O 操作的等待时间会浪费 CPU。
  • 另外, Android 还有一个专用的 AndroidSchedulers.mainThread(),它指定的操作将在 Android 主线程运行。

有了这几个 Scheduler ,就可以使用 subscribeOn()observeOn() 两个方法来对线程进行控制了。* subscribeOn(): 指定 subscribe() 所发生的线程,即 Observable.OnSubscribe 被激活时所处的线程。或者叫做事件产生的线程。* observeOn(): 指定 Subscriber 所运行在的线程。或者叫做事件消费的线程。

----------参考end----------

补充:

Schedulers.trampoline():返回一个默认共享的Scheduler,在一个参与的线程中以先进先出的顺序装载和执行任务。


Schedulers.single():返回一个默认共享的支持单例的Scheduler,用于需要在同一后台进程中顺序执行的任务


这上面说的还是可以用的,改造下代码:


或者玩玩其他的:

又或者

哈,Observer的onSubscribe总是在主进程被调用了,这也意味着那个方法里不能放耗时操作了。

待续。。。(对应参考博客 4. 变换)

这篇关于(十六) 试着使用RxJava的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/511444

相关文章

使用Python实现矢量路径的压缩、解压与可视化

《使用Python实现矢量路径的压缩、解压与可视化》在图形设计和Web开发中,矢量路径数据的高效存储与传输至关重要,本文将通过一个Python示例,展示如何将复杂的矢量路径命令序列压缩为JSON格式,... 目录引言核心功能概述1. 路径命令解析2. 路径数据压缩3. 路径数据解压4. 可视化代码实现详解1

Pandas透视表(Pivot Table)的具体使用

《Pandas透视表(PivotTable)的具体使用》透视表用于在数据分析和处理过程中进行数据重塑和汇总,本文就来介绍一下Pandas透视表(PivotTable)的具体使用,感兴趣的可以了解一下... 目录前言什么是透视表?使用步骤1. 引入必要的库2. 读取数据3. 创建透视表4. 查看透视表总结前言

Python 交互式可视化的利器Bokeh的使用

《Python交互式可视化的利器Bokeh的使用》Bokeh是一个专注于Web端交互式数据可视化的Python库,本文主要介绍了Python交互式可视化的利器Bokeh的使用,具有一定的参考价值,感... 目录1. Bokeh 简介1.1 为什么选择 Bokeh1.2 安装与环境配置2. Bokeh 基础2

SpringBoot UserAgentUtils获取用户浏览器的用法

《SpringBootUserAgentUtils获取用户浏览器的用法》UserAgentUtils是于处理用户代理(User-Agent)字符串的工具类,一般用于解析和处理浏览器、操作系统以及设备... 目录介绍效果图依赖封装客户端工具封装IP工具实体类获取设备信息入库介绍UserAgentUtils

Android使用ImageView.ScaleType实现图片的缩放与裁剪功能

《Android使用ImageView.ScaleType实现图片的缩放与裁剪功能》ImageView是最常用的控件之一,它用于展示各种类型的图片,为了能够根据需求调整图片的显示效果,Android提... 目录什么是 ImageView.ScaleType?FIT_XYFIT_STARTFIT_CENTE

Spring 中的循环引用问题解决方法

《Spring中的循环引用问题解决方法》:本文主要介绍Spring中的循环引用问题解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录什么是循环引用?循环依赖三级缓存解决循环依赖二级缓存三级缓存本章来聊聊Spring 中的循环引用问题该如何解决。这里聊

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》:本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter(过滤器)1. Filter 的工作原理2. Filter 的配置与使用二、Listen

Pandas使用AdaBoost进行分类的实现

《Pandas使用AdaBoost进行分类的实现》Pandas和AdaBoost分类算法,可以高效地进行数据预处理和分类任务,本文主要介绍了Pandas使用AdaBoost进行分类的实现,具有一定的参... 目录什么是 AdaBoost?使用 AdaBoost 的步骤安装必要的库步骤一:数据准备步骤二:模型

Spring Boot中JSON数值溢出问题从报错到优雅解决办法

《SpringBoot中JSON数值溢出问题从报错到优雅解决办法》:本文主要介绍SpringBoot中JSON数值溢出问题从报错到优雅的解决办法,通过修改字段类型为Long、添加全局异常处理和... 目录一、问题背景:为什么我的接口突然报错了?二、为什么会发生这个错误?1. Java 数据类型的“容量”限制

使用Pandas进行均值填充的实现

《使用Pandas进行均值填充的实现》缺失数据(NaN值)是一个常见的问题,我们可以通过多种方法来处理缺失数据,其中一种常用的方法是均值填充,本文主要介绍了使用Pandas进行均值填充的实现,感兴趣的... 目录什么是均值填充?为什么选择均值填充?均值填充的步骤实际代码示例总结在数据分析和处理过程中,缺失数