學習網(wǎng)站 https://kaixue.io/kotlin-coroutines-1/
記錄
Android
Add kotlinx-coroutines-android module as dependency when using kotlinx.coroutines on Android:
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.7'
文檔
https://www.kotlincn.net/docs/kotlin-docs.pdf
本質(zhì)上蚣驼，協(xié)程事輕量級的線程
基本使用
前面提到蒸痹，launch 函數(shù)不是頂層函數(shù)，是不能直接用的曼氛，可以使用下面三種方法來創(chuàng)建協(xié)程：
???
// 方法一度宦，使用 runBlocking 頂層函數(shù)
runBlocking {
getImage(imageId)
}
// 方法二誓酒，使用 GlobalScope 單例對象
// ?? 可以直接調(diào)用 launch 開啟協(xié)程
GlobalScope.launch {
getImage(imageId)
}
// 方法三钠惩，自行通過 CoroutineContext 創(chuàng)建一個 CoroutineScope 對象
// ?? 需要一個類型為 CoroutineContext 的參數(shù)
val coroutineScope = CoroutineScope(context)
coroutineScope.launch {
getImage(imageId)
}
Kotlin
- 方法一通常適用于單元測試的場景秕狰，而業(yè)務開發(fā)中不會用到這種方法，因為它是線程阻塞的东跪。
- 方法二和使用
runBlocking的區(qū)別在于不會阻塞線程畸陡。但在 Android 開發(fā)中同樣不推薦這種用法，因為它的生命周期會和 app 一致虽填，且不能取消（什么是協(xié)程的取消后面的文章會講）丁恭。 - 方法三是比較推薦的使用方法，我們可以通過
context參數(shù)去管理和控制協(xié)程的生命周期（這里的context和 Android 里的不是一個東西斋日，是一個更通用的概念牲览，會有一個 Android 平臺的封裝來配合使用）。
???
coroutineScope.launch(Dispatchers.Main) { // ?? 在 UI 線程開始
val image = withContext(Dispatchers.IO) { // ?? 切換到 IO 線程恶守，并在執(zhí)行完成后切回 UI 線程
getImage(imageId) // ?? 將會運行在 IO 線程
}
avatarIv.setImageBitmap(image) // ?? 回到 UI 線程更新 UI
}
練習題
- 開啟一個協(xié)程第献，并在協(xié)程中打印出當前線程名。
- 通過協(xié)程下載一張網(wǎng)絡圖片并顯示出來熬的。
package com.tic.planb
import android.graphics.Bitmap
import android.graphics.BitmapFactory
import androidx.appcompat.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import com.tic.plan.Plan
import kotlinx.android.synthetic.main.activity_main.*
import kotlinx.coroutines.*
import java.net.HttpURLConnection
import java.net.URL
class MainActivity : AppCompatActivity() {
private val TAG = "MainActivity"
val imgUrl =
"http://img1.gamersky.com/image2016/10/20161015_ls_141_5/gamersky_03origin_05_201610151947EAA.jpg"
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
CoroutineScope(Dispatchers.Main).launch {
Log.d(TAG, "當前線程${Thread.currentThread().name}")
val bitmap = withContext(Dispatchers.IO) {
Log.d(TAG, "當前線程${Thread.currentThread().name}")
getImage(imgUrl)
}
mImageIv.setImageBitmap(bitmap)
}
}
private fun getImage(imgUrl: String): Bitmap {
val urlParam = URL(imgUrl)
val openConnection = urlParam.openConnection() as HttpURLConnection
openConnection.requestMethod = "GET"
openConnection.connect()
val inputStream = openConnection.inputStream
return BitmapFactory.decodeStream(inputStream)
}
}
記得開網(wǎng)絡權(quán)限
Kotlin 協(xié)程的掛起好神奇好難懂痊硕？我今天把他的皮給扒了
-朱凱說的
接下來我們繼續(xù)看看 async 是如何使用的，先回憶一下上期中獲取頭像的場景：
???
coroutineScope.launch(Dispatchers.Main) {
// ?? async 函數(shù)啟動新的協(xié)程
val avatar: Deferred = async { api.getAvatar(user) } // 獲取用戶頭像
val logo: Deferred = async { api.getCompanyLogo(user) } // 獲取用戶所在公司的 logo
// ?? ?? 獲取返回值
show(avatar.await(), logo.await()) // 更新 UI
}
Kotlin
可以看到 avatar 和 logo 的類型可以聲明為 Deferred 押框，通過 await 獲取結(jié)果并且更新到 UI 上顯示岔绸。
在了解了 suspend 關鍵字的來龍去脈之后，我們就可以進入下一個話題了：怎么自定義 suspend 函數(shù)橡伞。
這個「怎么自定義」其實分為兩個問題：
- 什么時候需要自定義
suspend函數(shù)盒揉？ - 具體該怎么寫呢？
什么時候需要自定義 suspend 函數(shù)
如果你的某個函數(shù)比較耗時兑徘，也就是要等的操作刚盈，那就把它寫成 suspend 函數(shù)。這就是原則挂脑。
耗時操作一般分為兩類：I/O 操作和 CPU 計算工作藕漱。比如文件的讀寫、網(wǎng)絡交互崭闲、圖片的模糊處理肋联，都是耗時的，通通可以把它們寫進 suspend 函數(shù)里刁俭。
另外這個「耗時」還有一種特殊情況橄仍，就是這件事本身做起來并不慢，但它需要等待，比如 5 秒鐘之后再做這個操作侮繁。這種也是 suspend 函數(shù)的應用場景虑粥。
具體該怎么寫
給函數(shù)加上 suspend 關鍵字，然后在 withContext 把函數(shù)的內(nèi)容包住就可以了宪哩。
提到用 withContext是因為它在掛起函數(shù)里功能最簡單直接：把線程自動切走和切回娩贷。
當然并不是只有 withContext 這一個函數(shù)來輔助我們實現(xiàn)自定義的 suspend 函數(shù)，比如還有一個掛起函數(shù)叫 delay斋射，它的作用是等待一段時間后再繼續(xù)往下執(zhí)行代碼育勺。
使用它就可以實現(xiàn)剛才提到的等待類型的耗時操作：
???
suspend fun suspendUntilDone() {
while (!done) {
delay(5)
}
}
Kotlin
這些東西，在我們初步使用協(xié)程的時候不用立馬接觸罗岖，可以先把協(xié)程最基本的方法和概念理清楚。
練習
使用協(xié)程下載一張圖腹躁，并行進行兩次切割
- 一次切成大小相同的 4 份桑包，取其中的第一份
- 一次切成大小相同的 9 份，取其中的最后一份
得到結(jié)果后纺非，將它們展示在兩個 ImageView 上哑了。
package com.tic.planb
import android.app.ProgressDialog.show
import android.graphics.Bitmap
import android.graphics.BitmapFactory
import androidx.appcompat.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import com.tic.plan.Plan
import kotlinx.android.synthetic.main.activity_main.*
import kotlinx.coroutines.*
import java.net.HttpURLConnection
import java.net.URL
class MainActivity : AppCompatActivity() {
private val TAG = "MainActivity"
val imgUrl =
"http://img1.gamersky.com/image2016/10/20161015_ls_141_5/gamersky_03origin_05_201610151947EAA.jpg"
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
CoroutineScope(Dispatchers.Main).launch {
Log.d(TAG, "當前線程${Thread.currentThread().name}")
val bitmap = getImage(imgUrl)
mImageIv.setImageBitmap(bitmap)
val bitmap1 = cropBitmap(bitmap, 0, 0, bitmap.width / 2, bitmap.height / 2)
mImageIv2.setImageBitmap(bitmap1)
val bitmap2 = cropBitmap(
bitmap,
bitmap.width * 2 / 3,
bitmap.height * 2 / 3,
bitmap.width / 3,
bitmap.height / 3
)
mImageIv3.setImageBitmap(bitmap2)
}
}
/**
* 下載圖片，耗時
*/
private suspend fun getImage(imgUrl: String): Bitmap = withContext(Dispatchers.IO) {
Log.d(TAG, "當前線程${Thread.currentThread().name}")
val urlParam = URL(imgUrl)
val openConnection = urlParam.openConnection() as HttpURLConnection
openConnection.requestMethod = "GET"
openConnection.connect()
val inputStream = openConnection.inputStream
BitmapFactory.decodeStream(inputStream)
}
/**
* 切割圖片
* @param source The bitmap we are subsetting
* @param x The x coordinate of the first pixel in source
* @param y The y coordinate of the first pixel in source
* @param width The number of pixels in each row
* @param height The number of rows
*/
private suspend fun cropBitmap(
source: Bitmap,
x: Int,
y: Int,
width: Int,
height: Int
): Bitmap = withContext(Dispatchers.IO) {
Bitmap.createBitmap(source, x, y, width, height)
}
}
