我们为什么要用 flow

持续创作,加速成长!这是我参与「日新计划 6 月更文挑战」的第4天,点击查看活动详情

前言

首先,我们得明确 flow 的适用场景,那便是类似播报机情况,每隔一段时间就appetite播报一段相似携程网站官网的内容。由此,假如我们不使用 flow 的情况下,那我们怎么解决这种问题?

  • List ❎
  • sequence ❎

为什么appear这么快否决它们?因为他们都是阻approach塞式的,appointment每两个元素间隔的时间,都会阻塞相应的线线程池的七个参数,所以就不过多进行说明。
而另外两个选项可以实现 flow 的appointment效果,也就是可挂起式运行。

  • 回调
  • LiveData

回调

class MainActivity : AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        startDownloading { result -> println(result) }
    }
    private fun startDownloading(callBack: (String) -> Unit) {
        GlobalScope.launch(Dispatchers.IO) {
            callBack("开始下载")
            delay(100)
            callBack("进度为 33%")
            delay(100)
            callBack("进度为 66%")
            delay(100)
            callBack("进度为 100%")
            delay(100)
            callBack("下载完成")
        }
    }
}
I/System.out: 开始下载
I/System.out: 进度为 33%
I/System.out: 进度为 66%
I/System.out: 进度为 100%
I/System.out: 下载完成

LiveData

class MainActivity : AppCompatActivity() {
    val result = MutableLiveData<String>()
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        result.observe(this){ result ->
            println(result)
        }
        startDownloading()
    }
    private fun startDownloading() {
        GlobalScope.launch(Dispatchers.IO) {
            result.postValue("开始下载")
            delay(100)
            result.postValue("进度为 33%")
            delay(100)
            result.postValue("进度为 66%")
            delay(100)
            result.postValue("进度为 100%")
            delay(100)
            result.postValue("下载完成")
        }
    }
}

日志输出:

I/System.out: 开始下载
I/System.out: 进度为 33%
I/System.out: 进度为 66%
I/System.out: 进度为 100%
I/System.out: 下载完成

总结

em…回调,也就是观察者模式的代表,确实是可以实携程网上订票飞机现类似的效果,同时,LiveData 也是可以实现相应的效果的。

另外,从声明周期的角度来看,回调的方式和 flow 的方式默认都是不支持声明周期结束时自动取消的,而 LiveDataappetite 是支持的。

这里我们来验证下 flow 默线程安全认有没有自动取消的机制:

class MainActivity : AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        GlobalScope.launch {
            flow { delay(8000)
                emit(1)}.collect { value ->
                println("value -> $value")
            }
        }
    }
    override fun onDestroy() {
        super.onDestroy()
        println("onDestroy 已被执行")
    }
}

结果输出:

I/System.out: onDestroy 已被执行
I/System.out: value -> 1

em…这样看,那岂不是 LiveData 更胜一筹?那我们为什么还要用 flow,干脆直接用 LiveData 就算了?

当然,LiveData 是不能替代 flow 的,因为他们原本协程就是不同赛道的东西,只不过碰巧 LiveData 能够实现这种异步刷新的功能而已。

另外,正如为什么之前 Rx 系列这么火的原因?并不是他们 Rx 系列能够提供携程旅行app官方下载类似回调的功携程网飞机票预订官网能,而是他们拥有众多操作符,能够非常方便实现各种功能,而 flow 同样有这个优势,详情可以看看这篇「flow 操作符全kotlin怎么读解析」。

现在 协程+ flkotlin匿名函数ow 正在不断取代 Rx线程 系列的位置,成为主流。从未来的发展角度kotlin匿名函数来看,学习 flow 同样是一种趋势。

总结原因:

  • 支持挂起,能够协程进行完美交互
  • 拥有众多操作符,能够方便完成各项功能
  • Kotlin + flow 成为未来的发展趋线程数越多越好吗

发表评论

提供最优质的资源集合

立即查看 了解详情