首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

通过Rxjava看Kotlin协程(一)

我在kotlin的协程使用过程中,其实发现了很多rxjava和协程之间很相似的地方。 如果把两个东西孤立起来学习,我觉得成本太高了。...这个地方只是随手写的啊,可能会有bug的 suspendCoroutine 挂起函数 在异步编程中,回调是非常常见的写法,那么如何将回调转换为协程中的挂起函数呢?...可以通过两个挂起函数suspendCoroutine{}或suspendCancellableCoroutine{}。 这两个函数就是协程给我们提供的将异步回调写成挂起函数的方式。...但是吧,如果现在让我选,我还是觉得协程真香,毕竟链式调用一旦过长的情况下,其实对于开发的能力要求就越高。而kotlin协程的写法起码看起来更像是顺序执行,可读性和可维护性其实对后续来说会更好一点。...预告 下次我应该会写下关于协程的dispatcher和rxjava的Schedulers,我觉得这两个东西也还是很相似的。

1.1K31

通过RxJava看kotlin协程(二)

这篇文章主要和大家探讨下关于rxjava的Scheduler和协程的Dispatcher。 这两个东西的用处都是处理线程调度用的。...协程 Dispatcher 释义 协程上下文(coroutine context)包含一个协程调度器(参阅 CoroutineDispatcher),协程调度器 用于确定执行协程的目标载体,即运行于哪个线程...协程调度器可以将协程的执行操作限制在特定线程上,也可以将其分派到线程池中,或者让它无限制地运行。...结论 如果当你基本了解rxjava的调度器的实现的情况下。大胆点以后面试问你kotlin协程是如何实现调度的逻辑,你就把逻辑copy一遍告诉他就好了。...理解RxJava(三)线程调度原理分析 【译】kotlin 协程官方文档(4)-协程上下文和调度器(Coroutine Context and Dispatchers)

84751
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    Android Kotlin 协程async

    这就是async 可以帮助我们的地方。 在概念上,async 就类似于 launch。它启动了一个单独的协程与其它所有的协程一起并发的工作。...请注意,使用协程进行并发总是显式的。 惰性启动的 async 可选的,async 可以通过将 start 参数设置为 CoroutineStart.LAZY 而变为惰性的。...注意,如果我们只是在 println 中调用 await,而没有在单独的协程中调用 start,这将会导致顺序行为,直到 await 启动该协程 执行并等待至它结束,这并不是惰性的预期用例。...构建async 风格的函数 我们可以定义异步风格的函数来 异步 的调用 doSomethingUsefulOne 和 doSomethingUsefulTwo 并使用 async 协程建造器并带有一个显式的...在 Kotlin 的协程中使用这种风格是强烈不推荐的, 原因如下所述。

    1.5K20

    是继续Rxjava还是该试试Kotlin的协程?

    0.前言 协程以前一直是Kotlin作为实验性的一个库,前些日子发现1.3版本的kotlin relese了协程,所以就找时间研究了一下,本来早就想写这篇文章了,但是因为离职换工作的原因,迟迟未能动笔,...CoroutineScope中,创建CoroutineScop中传入参数Dispatchers.Main,这是一个协程调度器,它确定了相应的协程在执行时使用一个或多个线程。...协程调度器可以将协程的执行局限在指定的线程中,调度它运行在线程池中或让它不受限的运行。...关于协程还有一些其他的创建和使用方法,有兴趣的可以去看看官方教程。 3.Rxjava VS 协程 协程相对RxJava有什么优点呢?...(1)RxJava堆栈可读性查,一旦出现问题,堆栈信息爆炸,难以定位问题,而协程就可以避免这个问题 (2)协程用同步的方式写异步的代码,美好了生活,方便代码阅读。

    3.8K10

    Kotlin---协程的使用

    第一个协程 在使用协程之前,需要保证Kotlin-Gradle-Plugin的版本高于1.3。目前最高的版本为1.3.11。...并且这样执行的协程,并不会阻塞主线程的执行 delay函数只能在协程中使用,否则编译不过,尽量避免使用GlobalScope.launch创建协程,当我们使用 GlobalScope.launch 时...如果我们忘记保持对新启动的协程的引用,它还会继续运行。 阻塞的协程runBlocking GlobalScope.launch启动了一个线程创建新的协程,并没有阻塞当前线程。...但是这个函数必须使用suspend标识,否则编译错误,并且无法调用协程中到函数,比如delay()。...使用suspend标示的函数只能用于协程中,无法在其他函数中被调用 import kotlinx.coroutines.* fun main() = runBlocking { launch

    1.3K20

    Kotlin协程-特殊的阻塞协程

    阻塞协程是种特殊的协程启动方式,一般是用 runBlocking{} 扩起来一段协程。...这里给出结果,改用GlobalScope.launch之后,子协程会在一个独立的线程里运行。 runBlocking 在kotlin协程官网上对于这个api的解释是桥接阻塞与非阻塞的世界。...没有的话就使用默认的eventloop。EventLoop是协程里对阻塞型coroutine进行调度的默认调度器。runBlocking和launch的主要区别就靠EventLoop实现。...在创建完coroutine后就进入派发流程了,这部分和Kotlin协程-一个协程的生命周期中的逻辑比较相似,下面也会讲到。...这个问说明,runBLocking{}这种协程,它的运行逻辑是先把父协程放队列里,然后取出来执行,执行完毕再把子协程入队,再出队子协程,用同样的方式递归。

    2.5K20

    破解 Kotlin 协程(8) - Android 篇

    关键词:Kotlin 协程 Android Anko Android 上面使用协程来替代回调或者 RxJava 实际上是一件非常轻松的事儿,我们甚至可以在更大的范围内结合 UI 的生命周期做控制协程的执行状态...协程的原理和用法我们已经探讨了很多了,关于 Android 上面的协程使用,我们就只给出几点实践的建议。 2....合理使用调度器 在 Android 上使用协程,更多的就是简化异步逻辑的写法,使用场景更多与 RxJava 类似。...那么使用协程就更要注意这个问题了,因为协程切换线程的方式被 RxJava 更简洁,更透明,本来这是好事情,就怕被滥用。...一旦我们把协程的作用域规则以及协程与 UI 生命周期的关系熟稔于心,那么相信大家使用协程时一定会得心应手的。

    1.1K31

    Kotlin---使用协程的异步

    协程间的通信 协程与协程间不能直接通过变量来访问数据,会导致数据原子性的问题,所以协程提供了一套Channel机制来在协程间传递数据。...目前,在1.3.11版本的Kotlin中,produce与consume都还只是实验性的功能,没有正式release,使用时记得使用@ExperimentalCoroutinesApi标记使用的函数 runBlocking...它启动了一个单独的协程,这是一个轻量级的线程并与其它所有的协程一起并发的工作。...协程与线程一样,对于数据的操作无法保持原子性,所以在协程中,需要使用原子性的数据结构,例如AotimicInteger等,或者使用mutex.withLock,来处理数据的原子性 import kotlinx.coroutines...、被限制并封装到该协程中的状态以及一个与其它协程通信的 通道 组合而成的一个实体。

    2.8K20

    Android Kotlin协程间的通信Channel介绍

    前言 使用Kotlin做Android项目时,肯定少不了使用协程,而在协程的使用中,少不了要在不同的协程中传递数据,而Kotlin中的Channel,就是专门用来处理协程之间的通信,今天这篇就是来看看Channel...Channel简介 channel用于协程间的通信, 允许我们在不同的协程间传递数据。...上图中,因为满了3个后Send挂起,所以第一个协程(1-5)完后,第二个协程的11数字进去后也开始挂起了,这时的挂起也让第三个协程(21-25)的第一条进入到队列中。...这里就可以看出,当使用Channel.UNLIMITED时,完全是按钮协程调用的顺序输出的。...Kotlin使用协程时,还是会经常用Channel来处理协程之间的数据通信,更多的用法可以自己去多做尝试 完

    76140

    【Kotlin 协程】协程简介 ( 协程概念 | 协程作用 | 创建 Android 工程并进行协程相关配置开发 | 异步任务与协程对比 )

    文章目录 一、协程概念 二、协程作用 三、创建 Android 工程并进行协程相关配置 1、创建 Android 工程 2、配置协程环境 3、布局文件 4、异步任务代码示例 5、协程代码示例 6、完整代码示例...四、异步任务与协程对比 一、协程概念 ---- 协程 Coroutine 是 Kotlin 语言 中新出现的概念 , 在 Java 语言中没有 ; 协程 是 基于 线程 的 , 是 轻量级 线程 ;...二、协程作用 ---- 协程主要作用如下 : 处理耗时任务 : 耗时任务 通常需要 阻塞主线程 , 线程量级太重 , 耗时任务 推荐在协程中执行 ; 保证主线程安全 : 从主线程中 安全地调用可能会挂起的函数...包下的 Executor,ThreadPoolExecutor,FutureTask 取代 AsyncTask ; 三、创建 Android 工程并进行协程相关配置 ---- 1、创建 Android...; 注意选择 Kotlin 语言 , Android Studio 会自动添加 Kotlin 语言支持 ; 2、配置协程环境 在 AndroidManifest.xml 清单文件 中 , 添加网络权限

    4.4K20

    【Kotlin 协程】协程底层实现 ① ( Kotlin 协程分层架构 | 基础设施层 | 业务框架层 | 使用 Kotlin 协程基础设施层标准库 Api 实现协程 )

    文章目录 一、Kotlin 协程分层架构 二、使用 Kotlin 协程基础设施层标准库 Api 实现协程 一、Kotlin 协程分层架构 ---- Kotlin 协程分层架构 : 在 Kotlin 中..., 协程分为两层 ; 基础设施层 : Kotlin 提供了 协程 标准库 Api , 为协程提供 概念 , 语义 支持 , 是 协程 实现的基础 ; Kotlin 协程的底层支持 ; 基础 Api ;...业务框架层 : Kotlin 协程的 上层框架 , 使用方便 ; 在之前博客中使用的 GlobalScope 类 , launch 函数 , delay 挂起函数 等都属于 业务框架层 , 都是 Kotlin...协程 的上层实现 ; 在 基础 Api 的基础上 进行了一层封装 , 形成了方便开发者使用的框架 ; 基础设施层 : 基础设施层 的 协程基础 Api 定义在 kotlin.coroutines.*...和 Java 的基础 Api , 业务框架层 是 对 基础 Api 进行了一层封装的框架 , 如 RxJava , Retrofit , Glide 等 , 目的是为了方便开发 ; 二、使用 Kotlin

    85210

    【Kotlin 协程】协程异常处理 ④ ( Android 协程中出现异常导致应用崩溃 | Android 协程中使用协程异常处理器捕获异常 | Android 全局异常处理器 )

    文章目录 一、Android 协程中出现异常导致应用崩溃 二、Android 协程中使用协程异常处理器捕获异常 三、Android 全局异常处理器 一、Android 协程中出现异常导致应用崩溃 --...-- 在前几篇博客示例中 , 协程中 如果出现异常 , 没有进行捕获 , 则程序直接崩溃 , 这种情况下需要进行 异常的捕获 以 避免 Android 应用程序的崩溃 ; 示例代码 : package...协程中使用协程异常处理器捕获异常 ---- 在 Android 程序中 , 可以使用 协程异常处理器 CoroutineExceptionHandler 捕获异常 , 将其实例对象传递给 launch...全局异常处理器 ---- Android 中的 全局异常处理器 , 可以 获取 所有的 协程 中产生的 没有被捕获的异常 ; 无法阻止崩溃 : 全局异常处理器 不能捕获这些异常 进行处理 , 应用程序...: ⑥ 在 Activity 中实现一个 抛出异常的协程 : package kim.hsl.coroutine import android.os.Bundle import android.util.Log

    1.6K10

    【翻译】忘了RxJava吧——你需要的是拥抱Kotlin协程(Part 12)

    【翻译】忘了RxJava吧——你需要的是拥抱Kotlin协程(Part 1/2) 2018-08-31 by Liuqingwen | Tags: Kotlin Android 翻译 |...RxJava 需要您为异步代码的运行选择 Scheduler 调度,在协程代码中,类似的实体称为 Dispatcher 派发器。...那么关于我们在 RxJava 代码中找到的那些缺点去哪了呢?在协程中都解决了吗? 性能开销问题 协程代码产生的对象数量下降到了 11 (下降了三分之一)。 ?...在这里使用 runBlocking 是作为一个协程构建器,它能阻塞协同程序运行的所在线程。在这里查看更多。...概要 好吧,在这里我们设法重构一些使用了 Singles 的代码,替换为 Kotlin 协程并从中感受到一些好处。在此系列的下一章节中,我们将考虑使用协程来处理比 RxJava 更高级的一些主题。

    1.1K20

    java协程框架quasar和kotlin中的协程

    接下来要分享的这个开源项目,正是解决了在java中只能使用多线程模型开发高并发应用的窘境,使得java也能像Go语言那样使用协程的语义开发了。...,他标记了协程代码的起始和结束的位置,以及方法需要暂停的位置,每个协程任务统一由FiberScheduler去调度,内部维护了一个或多个ForkJoinPool实例。...而反观协程,基于固定的几个线程调度,可以轻松实现百万级的协程处理,而且内存稳稳的。 后记 最后,博主以为Quasar只是一个框架层面的东西,所以就又去看了下同样是jvm语言的kotlin的协程。...,有种震惊的赶脚,kotlin的同步模型牛逼呀,瞬时感觉到发现了java里的骚操作了,可以使用kotlin的协程来代替java中的多线程操作。...所以就有下面这个kotlin协程实现的代码: @Service class KotlinAsyncService(private val weatherService: GetWeatherService

    54330

    【Kotlin 协程】协程的挂起和恢复 ② ( 协程挂起 和 线程阻塞 对比 )

    文章目录 一、协程挂起 和 线程阻塞 对比 1、协程挂起 2、线程阻塞 3、挂起和阻塞对 UI 的影响 4、挂起分析 一、协程挂起 和 线程阻塞 对比 ---- 挂起是协程中的概念 , 只能在协程中使用...; 阻塞是线程中的概念 , 可以在主线程和子线程中使用 ; 1、协程挂起 协程 挂起 操作 : 在协程中使用 delay 函数 , 挂起 20 秒时间 , 然后 20 秒后更新 UI ; delay...Log.i("MainActivity", "GlobalScope : 主线程更新 UI") } 2、线程阻塞 主线程 阻塞 操作 : 在主线程 中使用 Thread.sleep 函数 , 阻塞 20...协程 挂起 操作 不会出现 阻塞 UI 刷新的情况 , 挂起的 20 秒不影响 UI 刷新显示 ; 但是如果将主线程阻塞 , UI 不再刷新 , 会出现 ANR 崩溃异常 ; 图形化 GUI 系统中..., 会将挂起点的状态保存 , 同时协程停止执行 , 等待挂起函数执行完毕后 , 协程继续执行 ; 相当于阻塞的是协程 , 不会阻塞主线程 ;

    1.8K20

    Kotlin中的协程及在Android中的应用

    前言 Kotlin协程底层是用线程实现的,是一个封装完善供开发者使用的线程框架。...Kotlin的一个协程可以理解为是运行在线程上的一个执行任务并且该任务可以在不同的线程间切换,一个线程可以同时运行多个协程。...从开发者角度来看:kotlin协程可以实现以同步的方式去编写异步执行的代码,解决线程切换回调的嵌套地狱。 协程挂起时不需要阻塞线程,几乎是无代价的。...比如:网络请求,数据库操作,文件操作等 Main:UI调度器,只有在UI编程平台上有意义,用于更新UI,例如Android中的主线程 Unconfined:非受限调度器,无所谓调度器,当前协程可以运行在任意线程上...Kotlin协程最大的优势就是以同步的方式写异步代码,这就是通过挂起函数用来实现。

    19010

    【Kotlin 协程】协程的挂起和恢复 ① ( 协程的挂起和恢复概念 | 协程的 suspend 挂起函数 )

    文章目录 一、协程的挂起和恢复概念 二、协程的 suspend 挂起函数 一、协程的挂起和恢复概念 ---- 函数 最基本的操作 是 : 调用 call : 通过 函数名或函数地址 调用函数 ; 返回...return : 函数执行完毕后 , 继续执行函数调用的下一行代码 ; 协程 在 调用 call 和 返回 return 基础上 , 又新增了两种 状态 : 挂起 Suspend : 暂停当前执行的协程..., 只能在 协程体内部 或者 其它挂起函数 中调用 ; 协程外部不允许使用挂起函数 ; 在协程中 , 执行 挂起 Suspend 函数 , 将 挂起点的信息 记录下来 , 然后执行耗时操作 , 执行完毕后...恢复 Resume ; 二、协程的 suspend 挂起函数 ---- 声明挂起函数 , 使用 suspend 在 fun 关键字之前 修饰函数 , 如 : public suspend fun Test...){} 中 , 可以直接调用挂起函数 ; 挂起 函数 , 只能在 协程体内部 或者 其它挂起函数 中调用 ; 协程外部不允许使用挂起函数 ; 在协程中 , 执行 挂起 Suspend 函数 , 将 挂起点的信息

    1.7K40
    领券