Coroutines in Android - One Shot and Multiple Values

来源:https://www.cnblogs.com/mengdd/archive/2019/12/06/kotlin-coroutines-flow-in-Android.html

在Android中, 我們用到的數據有可能是一次性的, 也有可能是需要多個值的. 本文介紹Android中結合協程(coroutines)的MVVM模式如何處理這兩種情況. 重點介紹協程`Flow`在Android中的應用. ...


Coroutines in Android - One Shot and Multiple Values

在Android中, 我們用到的數據有可能是一次性的, 也有可能是需要多個值的.

本文介紹Android中結合協程(coroutines)的MVVM模式如何處理這兩種情況. 重點介紹協程Flow在Android中的應用.

One-shot vs multiple values

實際應用中要用到的數據可能是一次性獲取的(one-shot), 也可能是多個值(multiple values), 或者稱為流(stream).

舉例, 一個微博應用中:

  • 微博信息: 請求的時候獲取, 結果返回即完成. -> one-shot.
  • 閱讀和點贊數: 需要觀察持續變化的數據源, 第一次結果返回並不代表完成. -> multiple values, stream.

MVVM構架中的數據類型

一次性操作和觀察多個值(流)的數據, 在架構上看起來會有什麼不同呢?

  • One-shot operation: ViewModel中是LiveData, Repository和Data source中是suspend fun.
class MyViewModel {
    val result = liveData {
        emit(repository.fetchData())
    }
}

多個值的實現有兩種選擇:

  • Multiple values with LiveData: ViewModel, Repository, Data source都返回LiveData. 但是LiveData其實並不是為流式而設計的, 所以用起來會有點奇怪.
  • Streams with Flow: ViewModel中是LiveData, Repository和Data source返回Flow.

可以看出兩種方式的主要不同點就是ViewModel消費的數據形式, 是LiveData還是Flow.

後面會從ViewModel, Repository和Data source三個層面來說明.

Flow是什麼

既然提到了Flow, 我們先來簡單講一下它是什麼, 這樣大家能在same page.

Kotlin中的多個值, 可以存儲在集合中, 比如list, 也可以靠計算生成sequence, 但如果值是非同步生成的, 需要將方法標記為suspend來避免阻塞主線程.

flow和sequence類似, 但flow是非阻塞的.

看這個例子:

fun foo(): Flow<Int> = flow {
    // flow builder
    for (i in 1..3) {
        delay(1000) // pretend we are doing something useful here
        emit(i) // emit next value
    }
}

fun main() = runBlocking<Unit> {
    // Launch a concurrent coroutine to check if the main thread is blocked
    launch {
        for (k in 1..3) {
            println("I'm not blocked $k")
            delay(1000)
        }
    }
    // Collect the flow
    foo().collect { value -> println(value) }
}

這段代碼執行後輸出:

I'm not blocked 1
1
I'm not blocked 2
2
I'm not blocked 3
3
  • 這裡用來構建Flow的flow方法是一個builder function, 在builder block里的代碼可以被suspend.
  • emit方法負責發送值.
  • cold stream: 只有調用了terminal operation才會被激活. 最常用的是collect().

如果熟悉Reactive Streams, 或用過RxJava就可以感覺到, Flow的設計看起來很類似.

ViewModel層

發送單個值的情況比較簡單和典型, 這裡不再多說, 主要說發送多個值的情況. 每次又分ViewModel消費的類型是LiveData還是Flow兩種情況來討論.

發射N個值

LiveData -> LiveData

val currentWeather: LiveData<String> = dataSource.fetchWeather()

Flow -> LiveData

val currentWeatherFlow: LiveData<String> = liveData {
    dataSource.fetchWeatherFlow().collect {
        emit(it)
    }
}

為了減少boilerplate代碼, 簡化寫法:

val currentWeatherFlow: LiveData<String> = dataSource.fetchWeatherFlow().asLiveData()

後面都直接用這種簡化的形式了.

發射1+N個值

LiveData -> LiveData

val currentWeather: LiveData<String> = liveData {
    emit(LOADING_STRING)
    emitSource(dataSource.fetchWeather())
}

emitSource()發送的是一個LiveData.

Flow -> LiveData

Flow的時候可以用上面同樣的形式:

val currentWeatherFlow: LiveData<String> = liveData {
    emit(LOADING_STRING)
    emitSource(
        dataSource.fetchWeatherFlow().asLiveData()
    )
}

這樣寫看起來有點奇怪, 可讀性不好, 所以可以利用Flow的API, 寫成這樣:

val currentWeatherFlow: LiveData<String> = 
dataSource.fetchWeatherFlow()
    .onStart{emit(LOADING_STRING)}
    .asLiveData()

Suspend transformation

如果想在ViewModel中做一些轉換.

LiveData -> LiveData

val currentWeatherLiveData: LiveData<String> = dataSource.fetchWeather().switchMap {
    liveData { emit(heavyTransformation(it)) }
    
}

這裡不太適合用map來做轉換, 因為是在主線程.

Flow -> LiveData

Flow來做轉換就很方便:

val currentWeatherFlow: LiveData<String> = dataSource.fetchWeatherFlow()
    .map{ heavyTransformation(it) }
    .asLiveData()

Repository層

Repository層通常用來組裝和轉換數據.
LiveData被設計的初衷並不是做這些轉換的.
Flow則提供了很多有用的操作符, 所以顯然是一種更好的選擇:

val currentWeatherFlow: Flow<String> =
    dataSource.fetchWeatherFlow()
        .map { ... }
        .filter { ... }
        .dropWhile { ... }
        .combine { ... }
        .flowOn(Dispatchers.IO)
        .onCompletion { ... }

Data Source層

Data Source層是網路和資料庫, 通常會用到一些第三方的庫.
如果用了支持協程的庫, 如Retrofit和Room, 那麼只需要把方法標記為suspend的, 就行了.

  • Retrofit supports coroutines from 2.6.0
  • Room supports coroutines from 2.1.0

One-shot operations

對於一次性操作比較簡單, 數據層的只要suspend方法返回值就可以了.

suspend fun doOneShot(param: String) : String = retrofitClient.doSomething(param)

如果所用的網路或者資料庫不支持協程, 有辦法嗎? 答案是肯定的.
suspendCoroutine來解決.

比如你用的第三方庫是基於callback的, 可以用suspendCancellableCoroutine來改造one-shot operation:

suspend fun doOneShot(param: String): Result<String> = 
suspendCancellableCoroutine { continuation -> 
    api.addOnCompleteListener { result -> 
        continuation.resume(result)
    }.addOnFailureListener { error -> 
        continuation.resumeWithException(error)
    }.fetchSomething(param)
}

如果協程被取消了, 那麼resume會被忽略.

驗證代碼如期工作後, 可以做進一步的重構, 把這部分抽象出來.

Data source with Flow

數據層返回Flow, 可以用flow builder:

fun fetchWeatherFlow(): Flow<String> = flow {
    var counter = 0
    while(true) {
        counter++
        delay(2000)
        emit(weatherConditions[counter % weatherConditions.size])
    }
}

如果你所用的庫不支持Flow, 而是用回調, callbackFlow builder可以用來改造流.

fun flowFrom(api: CallbackBasedApi): Flow<T> = callbackFlow {
    val callback = object: Callback {
        override fun onNextValue(value: T) {
            offer(value)
        }
        
        override fun onApiError(cause: Throwable) {
            close(cause)
        }
        
        override fun onCompleted() = close()
    }
    api.register(callback)
    awaitClose { api.unregister(callback) }
}

可能並不需要LiveData

在上面的例子中, ViewModel仍然保持了自己向UI暴露的數據是LiveData類型. 那麼有沒有可能不用LiveData呢?

lifecycleScope.launchWhenStarted {
    viewModel.flowToFlow.collect {
        binding.currentWeather.text = it
    }
}

這樣其實和用LiveData是一樣的效果.

參考

視頻:

文檔:

博客:

最後, 歡迎關註微信公眾號: 聖騎士Wind
微信公眾號


您的分享是我們最大的動力!

更多相關文章
  • 總的來說,為四大步: 1.註冊Earthdata用戶。 註冊時需註意的是,最好把所有需打勾的都勾上,在最後【註冊】按鈕前,彈出【人機驗證】才能註冊成功。如果註冊不成功,除了檢查用戶名和密碼是否符合要求外,換臺電腦試試。 2.下載wget(網頁抓取工具)。 註意在Earthdata的具體數據下載【GH ...
  • 記錄一下/ --備份資料庫 use [master] go BACKUP DATABASE [LnkSys11] TO DISK = N'C:\BackUp\LnkSys11.bak' WITH --備份文件存放路徑 NOFORMAT, INIT, --INIT:覆蓋備份;NOINIT: 追加備份 ...
  • https://sqlserver.code.blog/2019/12/06/use-azure-data-studio-to-create-external-table-for-oracle-server/ ...
  • 一、主伺服器配置 1、配置文件my.cnf的修改 [[email protected] mysql]# vim /etc/my.cnf #在[mysqld]中添加:server-id=1log_bin=master-binlog_bin_index=master-bin.indexbinlog_do_db ...
  • mysql是一種關係型資料庫,是為了表示事物與事物之間的關係,本身存於資料庫中的內容意義並不大,所以廣泛應用於編程語言中,python中九含有與MySQL交互的模塊 pymysql 編程對mysql的操作 ...
  • 資料庫數據量很大的資料庫導入到本地時,會等很久,然而等很久之後還是顯示失敗; 這是就要看看自己本地的沒mysql是否設置了超時等待,如果報相關time_out這些,可以把mysql.ini尾部添加max_allowed_packet、interactive_timeout、wait_timeout ...
  • [20191206]隱含參數_db_always_check_system_ts.txt--//今年年頭我做tab$刪除恢復時,遇到的問題,就是遇到延遲塊清除的問題.參考鏈接:http://blog.itpub.net/267265/viewspace-2564716/http://blog.itp ...
  • 一、基礎信息 1. Centos7.4 2.MySQL 5.7.21 3.基於gtid的複製 二、異常描述 誤把從節點當成主節點插入一條數據,同一條數據在主、從節點插入都進行了一次插入操作,導致主鍵衝突,slave下的SQL線程異常。 建議設置從庫為只讀: set global read_only= ...
一周排行
  • " 返回《C 併發編程》" "1. 概念介紹" "2. 非同步編程" "2.1. async運行過程" "2.2. async運行中同步上下文簡介" "2.3. 創建Task實例" "2.4. 捕獲非同步異常類型" "3. 並行編程" "3.1. Parallel" "3.2. 異常處理" "3.3. ...
  • 我們先看看兩個特效,感受一下,有沒有學習的動力? 核心API:Texture2D.SetPixel(int x, int y, Color color),Texture2D.Apply() 實現原理:對象池 思路: 第一幀繪製前:遍歷瓦片上所有活著的粒子對象並且進行數據操作(或運動,死亡),發生運動 ...
  • 原來的導出方式比較適用於比較簡單的導出,每一條數據在一行,數據列雖然自定義程度比較高,如果要一條數據對應多行就做不到了,於是就想支持根據模板導出,在 1.8.0 版本中引入了根據模板導出的功能 ...
  • 創建一個bat腳本, 裡面寫上: reg delete HKEY_CURRENT_USER\Software\JetBrains\dotMemory /freg delete HKEY_CURRENT_USER\Software\Microsoft\Windows\CurrentVersion\Ex ...
  • Linux下有vsyscall來優化一些例如time(NULL), gettimeofday這種調用的消耗; 但是Windows下, 沒有類似的東西, 但是思路還是有的 1. 程式啟動的時候, 獲取一下準確的時間戳 2. 然後每次需要獲取時間的時候, 獲取一下流逝的時間, 可以通過獲取CPU的tic ...
  • 當用戶按下鍵盤上的一個鍵時,就會發生一系列事件。下表根據他們的發生順序列出了這些事件: 表 所有元素的鍵盤事件(按順序) 鍵盤處理永遠不會像上面看到的這麼簡單。一些控制項可能會掛起這些事件中的某些事件,從而可執行自己更特殊的鍵盤處理。最明顯的例子是TextBox控制項,它掛起了TextInput事件。對 ...
  • static void LocalMethod() { Cube(100); void Cube(int x) => Console.WriteLine($"The cube of {x} is {x * x * x}"); } static void GoToDemo() { int i = 1; ...
  • 滑鼠事件執行幾個關聯的任務。當滑鼠移到某個元素上時,可通過最基本的滑鼠事件進行響應。這些事件是MouseEnter(當滑鼠指針移到元素上時引發該事件)和MouseLeave(當滑鼠指針離開元素時引發該事件)。這兩個事件都是直接事件,這意味著他們不使用冒泡和隧道過程,而是源自一個元素並且只被該元素引發 ...
  • 反射這個詞聽起來就很牛逼是吧? 嗯的確,反射是比較高級的特性,只有語言基礎很扎實的Dev們才應該使用它。 搞點反射,可以提高程式的靈活性、可擴展性、耦合度。 反射這東西,是為了動態地運行時載入,相比於靜態代碼。編譯的時候就是板上釘釘了。 就是說,如果你的程式需要在運行時搞一些晚綁定,動態載入或檢查對 ...
  • 眾所周知,微服務架構是由一眾微服務組成,項目中調用其他微服務介面更是常見的操作。為了便於調用外部介面,我們的常用思路一般都是封裝一個外部介面的客戶端,使用時候直接調用相應的方法。webservice或WCF的做法就是引用服務,自動生成客戶端。在webapi2.0里,我們都會手動封裝一個靜態類。那麼在 ...
x