Android协程作用域与序列发生器限制介绍梳理
一.受限协程作用域
在协程的基础与使用中提到,可以通过sequence方法构建一个序列发生器。但当在sequence方法中调用除了yield方法与yieldAll方法以外的其他挂起方法时,就会报错。比如在sequence方法中调用delay方法,就会产生下面的报错提示:
翻译过来大致是“受限的挂起方法只能调用自身受限的协程作用域内的成员变量或挂起方法。这是什么意思呢?
1.sequence方法
sequence方法就是构建序列发生器用到的方法,内部通过Sequence方法实现,代码如下:
@SinceKotlin("1.3") public fun <T> sequence(@BuilderInference block: suspend SequenceScope<T>.() -> Unit): Sequence<T> = Sequence { iterator(block) }
其中参数block是一个在SequenceScope环境下的lambda表达式。
2.SequenceScope类
// 注意 @RestrictsSuspension @SinceKotlin("1.3") public abstract class SequenceScope<in T> internal constructor() { // 向迭代器中提供一个数值 public abstract suspend fun yield(value: T) // 向迭代器中提供一组数值 public abstract suspend fun yieldAll(iterator: Iterator<T>) // 向迭代器中提供Collection类型的一组数值 public suspend fun yieldAll(elements: Iterable<T>) { if (elements is Collection && elements.isEmpty()) return return yieldAll(elements.iterator()) } // 向迭代器中提供Sequence类型的一组数值 public suspend fun yieldAll(sequence: Sequence<T>) = yieldAll(sequence.iterator()) }
SequenceScope类是一个独立的抽象类,没有继承任何的类。它提供了四个方法,只要都是用来向外提供数值或对象。而该类成为受限协程作用域的关键在于该类被RestrictsSuspension注解修饰,代码如下:
@SinceKotlin("1.3") @Target(AnnotationTarget.CLASS) @Retention(AnnotationRetention.BINARY) public annotation class RestrictsSuspension
RestrictsSuspension注解用于修饰一个类或接口,表示该类是受限的。在被该注解修饰的类的扩展挂起方法中,只能调用该注解修饰的类中定义的挂起方法,不能调用其他类的挂起方法。
具体的,在sequence方法中,block就是SequenceScope类的扩展方法,因此在block中,只能使用SequenceScope类中提供的挂起方法——yield方法和yieldAll方法。同时,SequenceScope类的构造器被internal修饰,无法在外部被继承,因此也就无法定义其他的挂起方法。
为什么受限协程作用域不允许调用其他的挂起方法呢?
因为当一个方法挂起协程时,会获取协程的续体,同时协程需要等待方法执行完毕后的回调,这意味着会暴露协程的续体。可能会造成挂起协程执行的不确定性。
二.序列发生器
1.Sequence接口
首先来分析一下Sequence接口,代码如下:
public interface Sequence<out T> { public operator fun iterator(): Iterator<T> }
2.Sequence方法
在协程中,有一个与Sequence接口同名的方法,该方法用于返回一个实现了Sequence接口的对象,代码如下:
@kotlin.internal.InlineOnly public inline fun <T> Sequence(crossinline iterator: () -> Iterator<T>): Sequence<T> = object : Sequence<T> { override fun iterator(): Iterator<T> = iterator() }
Sequence方法返回了一个匿名对象,并通过参数中的lambda表达式iterator实现了接口中的iterator方法。
从sequence方法的代码可以知道,用于构建序列发生器的sequence方法内部调用了Sequence方法,同时还调用了iterator方法,将返回的Iterator对象,作为Sequence方法的参数。
3.iterator方法
@SinceKotlin("1.3") public fun <T> iterator(@BuilderInference block: suspend SequenceScope<T>.() -> Unit): Iterator<T> { val iterator = SequenceBuilderIterator<T>() iterator.nextStep = block.createCoroutineUnintercepted(receiver = iterator, completion = iterator) return iterator }
iterator方法内部创建了一个SequenceBuilderIterator对象,并且通过createCoroutineUnintercepted方法创建了一个协程,保存到了SequenceBuilderIterator对象的nextStep变量中。可以发现,序列发生器的核心实现都在SequenceBuilderIterator类中。
4.SequenceBuilderIterator类
SequenceBuilderIterator类是用于对序列发生器进行迭代,在该类的内部对状态进行了划分,代码如下:
private typealias State = Int // 没有要发射的数据 private const val State_NotReady: State = 0 private const val State_ManyNotReady: State = 1 // 有要发射的数据 private const val State_ManyReady: State = 2 private const val State_Ready: State = 3 // 数据全部发射完毕 private const val State_Done: State = 4 // 发射过程中出错 private const val State_Failed: State = 5
状态转移图如下:
迭代器的初始状态为State_NotReady,由于首次发射没有数据,因此会进入State_Failed状态。
State_Failed状态会从序列发生器中获取数据,如果是通过yield方法获取的数据,则会进入State_Ready状态,如果是通过yieldAll方法获取的数据,则会进入State_ManyReady状态。
当从序列发生器中获取数据时,如果是在State_ManyReady和State_Ready状态,则直接发射一个数据,对应的进入到State_ManyNotReady和State_NotReady状态。如果是在State_ManyNotReady和State_NotReady状态,则会判断是否有数据,如果有数据则对应进入到State_ManyReady和State_Ready状态。如果没有则进入到State_Failed状态,获取数据。
当序列发生器发射完毕时,会进入State_Done状态。
接下来对SequenceBuilderIterator类进行分析。
1.SequenceBuilderIterator类的全局变量
SequenceBuilderIterator类继承自SequenceScope类,实现了Iterator接口和Continuation接口。代码如下:
private class SequenceBuilderIterator<T> : SequenceScope<T>(), Iterator<T>, Continuation<Unit> { // 迭代器的状态 private var state = State_NotReady // 迭代器下一个要发送的值 private var nextValue: T? = null // 用于保存yieldAll方法传入的迭代器 private var nextIterator: Iterator<T>? = null // 用于获取下一个数据的续体 var nextStep: Continuation<Unit>? = null ... // 空的上下文 override val context: CoroutineContext get() = EmptyCoroutineContext }
为什么SequenceBuilderIterator类的上下文是空的呢?
因为SequenceBuilderIterator类继承了SequenceScope类,因此该类也是受限的,因此不允许在类的扩展方法中调用类内以外的挂起方法。自然也就不能进行调度、拦截等操作,所以上下文为空。在协程中,受限协程的上下文一般都是空上下文。
2.yield方法与yieldAll方法
yield方法与yieldAll方法是SequenceScope类中定义的两个方法,在SequenceBuilderIterator类中的实现如下:
// 发射一个数据 override suspend fun yield(value: T) { // 保存数据到全局变量中 nextValue = value // 修改状态 state = State_Ready // 挂起协程,获取续体 return suspendCoroutineUninterceptedOrReturn { c -> // 保存续体到全局变量中 nextStep = c // 挂起 COROUTINE_SUSPENDED } } // 发射多个数据 override suspend fun yieldAll(iterator: Iterator<T>) { // 如果迭代器没有数据,则直接返回 if (!iterator.hasNext()) return // 如果有数据,则保存到全局变量 nextIterator = iterator // 修改状态 state = State_ManyReady // 挂起协程,获取续体 return suspendCoroutineUninterceptedOrReturn { c -> // 保存续体到全局变量中 nextStep = c // 挂起 COROUTINE_SUSPENDED } }
通过上面的代码可以知道,yield方法和yieldAll方法主要做了三件事情,挂起协程、修改状态、保存要发送的数据和续体。而yieldAll发射多个数据原理在于保存了参数中Iterator接口指向的对象,通过迭代器获取数据。
3.hasNext方法
hasNext方法是Iterator接口中定义的方法,用于迭代时判断是否还有数据,代码如下:
override fun hasNext(): Boolean { // 循环 while (true) { // 判断状态 when (state) { // 刚通过yield方法发射数据 State_NotReady -> {} // 刚通过yieldAll方法发射数据 State_ManyNotReady -> // 如果迭代器中还有数据 if (nextIterator!!.hasNext()) { // 修改状态,返回true state = State_ManyReady return true } else { // 没有数据,则置空,丢弃迭代器 nextIterator = null } // 如果序列发生器已经发射完数据,返回false State_Done -> return false // 如果有数据,则直接返回true State_Ready, State_ManyReady -> return true // 其他状态,则抛出异常 else -> throw exceptionalState() } // 走到这里,说明需要去获取下一个数据 // 修改状态 state = State_Failed // 获取全局保存的续体 val step = nextStep!! // 置空 nextStep = null // 恢复序列发生器的执行,直到遇到yield方法或yieldAll方法挂起 step.resume(Unit) } } // 异常状态的处理 private fun exceptionalState(): Throwable = when (state) { State_Done -> NoSuchElementException() State_Failed -> IllegalStateException("Iterator has failed.") else -> IllegalStateException("Unexpected state of the iterator: $state") }
4.next方法
next方法也是Iterator接口中定义的方法,用于在迭代器中存在数据时获取数据,代码如下:
override fun next(): T { // 判断状态 when (state) { // 如果当前处于已经发射完数据的状态,则判断是否有数据 State_NotReady, State_ManyNotReady -> return nextNotReady() // 如果通过yieldAll方法获取到了数据 State_ManyReady -> { // 修改状态 state = State_ManyNotReady // 通过迭代器获取数据 return nextIterator!!.next() } // 如果通过yield方法获取到了数据 State_Ready -> { // 修改状态 state = State_NotReady // 获取保存的数据并进行类型转换 @Suppress("UNCHECKED_CAST") val result = nextValue as T // 全局变量置空 nextValue = null // 返回数据 return result } // 其他情况,则抛出异常 else -> throw exceptionalState() } } // 如果没有数据,则抛出异常,有数据,则返回数据 private fun nextNotReady(): T { if (!hasNext()) throw NoSuchElementException() else return next() }
5.总结
当使用序列发生器进行迭代时,首先会调用hasNext方法,hasNext方法会通过保存的续体,恢复序列发生器所在的协程继续执行,获取下一次待发射的数据。如果获取了到数据,则会返回true,这样之后通过next方法就可以获取到对应的数据。
当序列发生器所在的协程在执行中遇到yield方法时,会发生挂起,同时将下一次待发射的数据保存起来。如果遇到的是yieldAll方法,则保存的是迭代器,下一次发射数据时会从迭代器中获取。
到此这篇关于Android协程作用域与序列发生器限制介绍梳理的文章就介绍到这了,更多相关Android协程作用域内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
原文出处:https://blog.csdn.net/LeeDuoZuiShuai/article/details/1263233
相关文章
- 下面我们来看一篇关于Android子控件超出父控件的范围显示出来方法,希望这篇文章能够帮助到各位朋友,有碰到此问题的朋友可以进来看看哦。 <RelativeLayout xmlns:an...2016-10-02
Android开发中findViewById()函数用法与简化
findViewById方法在android开发中是获取页面控件的值了,有没有发现我们一个页面控件多了会反复研究写findViewById呢,下面我们一起来看它的简化方法。 Android中Fin...2016-09-20- 如果我们的项目需要做来电及短信的功能,那么我们就得在Android模拟器开发这些功能,本来就来告诉我们如何在Android模拟器上模拟来电及来短信的功能。 在Android模拟...2016-09-20
- 夜神android模拟器如何设置代理呢?对于这个问题其实操作起来是非常的简单,下面小编来为各位详细介绍夜神android模拟器设置代理的方法,希望例子能够帮助到各位。 app...2016-09-20
- 为了增强android应用的用户体验,我们可以在一些Button按钮上自定义动态的设置一些样式,比如交互时改变字体、颜色、背景图等。 今天来看一个通过重写Button来动态实...2016-09-20
- 如果我们要在Android应用APP中加载html5页面,我们可以使用WebView,本文我们分享两个WebView加载html5页面实例应用。 实例一:WebView加载html5实现炫酷引导页面大多...2016-09-20
- 深入理解Android中View和ViewGroup从组成架构上看,似乎ViewGroup在View之上,View需要继承ViewGroup,但实际上不是这样的。View是基类,ViewGroup是它的子类。本教程我们深...2016-09-20
- 下面我们来看一篇关于Android自定义WebView网络视频播放控件开发例子,这个文章写得非常的不错下面给各位共享一下吧。 因为业务需要,以下代码均以Youtube网站在线视...2016-10-02
- java开发的Android应用,性能一直是一个大问题,,或许是Java语言本身比较消耗内存。本文我们来谈谈Android 性能优化之MemoryFile文件读写。 Android匿名共享内存对外A...2016-09-20
- TextView默认是横着显示了,今天我们一起来看看Android设置TextView竖着显示如何来实现吧,今天我们就一起来看看操作细节,具体的如下所示。 在开发Android程序的时候,...2016-10-02
android.os.BinderProxy cannot be cast to com解决办法
本文章来给大家介绍关于android.os.BinderProxy cannot be cast to com解决办法,希望此文章对各位有帮助呀。 Android在绑定服务的时候出现java.lang.ClassCastExc...2016-09-20- 这篇文章主要介绍了Android 实现钉钉自动打卡功能的步骤,帮助大家更好的理解和学习使用Android,感兴趣的朋友可以了解下...2021-03-15
- 下面我们来看一篇关于Android 开发之布局细节对比:RTL模式 ,希望这篇文章对各位同学会带来帮助,具体的细节如下介绍。 前言 讲真,好久没写博客了,2016都过了一半了,赶紧...2016-10-02
- 首先如果要在程序中使用sdcard进行存储,我们必须要在AndroidManifset.xml文件进行下面的权限设置: 在AndroidManifest.xml中加入访问SDCard的权限如下: <!--...2016-09-20
- 下面来给各位简单的介绍一下关于Android开发之PhoneGap打包及错误解决办法,希望碰到此类问题的同学可进入参考一下哦。 在我安装、配置好PhoneGap项目的所有依赖...2016-09-20
用Intel HAXM给Android模拟器Emulator加速
Android 模拟器 Emulator 速度真心不给力,, 现在我们来介绍使用 Intel HAXM 技术为 Android 模拟器加速,使模拟器运行度与真机比肩。 周末试玩了一下在Eclipse中使...2016-09-20- 在安卓开发时我碰到一个问题就是需要实现全屏,但又需要我们来判断出用户是使用了全屏或非全屏了,下面我分别找了两段代码,大家可参考。 先来看一个android屏幕全屏实...2016-09-20
Android开发中布局中的onClick简单完成多控件时的监听的利与弊
本文章来为各位介绍一篇关于Android开发中布局中的onClick简单完成多控件时的监听的利与弊的例子,希望这个例子能够帮助到各位朋友. 首先在一个控件加上这么一句:and...2016-09-20Ubuntu 系统下安装Android开发环境 Android Studio 1.0 步骤
Android Studio 是一个Android开发环境,基于IntelliJ IDEA. 类似 Eclipse ADT,Android Studio 提供了集成的 Android 开发工具用于开发和调试,可以在Linux,Mac OS X,Window...2016-09-20- 这篇文章主要为大家详细介绍了Android实现简单用户注册案例,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2020-05-26