前言
Kotlin協程提供了一種新的異步執行方式，但直接查看庫函數可能會有點混亂，本文中嘗試揭開協程的神秘面紗。
理論
它是什么
這是別人翻譯: 協程把異步編程放入庫中來簡化這類操作。程序邏輯在協程中順序表述，而底層的庫會將其轉換為異步操作。庫會將相關的用戶代碼打包成回調，訂閱相關事件，調度其執行到不同的線程（甚至不同的機器），而代碼依然想順序執行那么簡單。
我的理解：子任務程協作運行，優雅的處理異步問題解決方案。
它能干什么?
我在做安卓開發，它能替換掉Handler,AsyncTask 甚至是Rxjava來優雅的解決異步問題。
下面讓我們從基礎開始吧，假設有一個名為launch可以用來啟動協程
private fun myHeavyFunction() { Log.e("Thread Running ", Thread.currentThread().name)}val job = launch { myHeavyFunction() }上面的代碼是使用launch一種非常簡單的方法，返回Job一個異步執行函數，Job代表一個協程coroutine作業，可以取消或查詢它的狀態。
override fun onStop() { if (job.isActive) { job.cancel() }}現在，如果查看我們的日志，檢查我們的函數實際運行的是哪個線程？我們就會得到類似的結果
E / Thread運行：ForkJoinPool.commonPool-worker-2
我們的代碼是在一個線程中運行的，讓我們稍微了解一下launch本身:
public fun launch( context:CoroutineContext =DefaultDispatcher, start:CoroutineStart CoroutineStart.DEFAULT, parent:Job?=null, onComp1etion:CompletionHand1er? =null, block:suspend CoroutineScope.()->Unit):Job{ 再看看DefaultDispatcher的值是什么？
@Suppress("PropertyName ") public actual val DefaultDispatcher: CoroutineDispatcher = CommonPoolobject CommonPool:CoroutineDispatcher()launch是將CoroutineContext作為第一個參數，這個參數值默認為代表一個CommonPool線程池類的DefaultDispatcher，這個線程池類根據當前CPU處理器總數創建一個帶有Executors的CoroutineContext。完整代碼在這里。
launch是一種協程構建器，可以接受一個協程分配器CoroutineDispatcher，分配器實際上負責在單獨的線程中運行代碼。
我們可以輕松創建自己的分配器：
val singleThreadDispatcher = newSingleThreadContext("singleThreadDispatcher")newSingleThreadContext 由Kotlin協同程序庫本身提供，用于創建僅在單個線程上運行的上下文。我們可以在此基礎上創建自己的函數：
fun <T> singleThreadAsync(block: () -> T): Job = launch(singleThreadDispatcher) { block.invoke() }job = singleThreadAsync { myHeavyFunction() }下面是運行后的日志
E / Thread運行：singleThreadDispatcher
所以我們用我們自己的線程方案創建了我們自己的簡單協程:)
讓我們看看我們可以通過Dispatchers做更多事情：
object MyDispatcher : CoroutineDispatcher() { override fun dispatch(context: CoroutineContext, block: Runnable) { thread { block.run() } }}object RxDispatcher : CoroutineDispatcher() { override fun dispatch(context: CoroutineContext, block: Runnable) { Observable.fromCallable { block.run() } .subscribeOn(Schedulers.io()) .subscribe {} }}object UIDispatcher : CoroutineDispatcher() { override fun dispatch(context: CoroutineContext, block: Runnable) { Handler(Looper.getMainLooper()).post { block.run() } }}在這里，我們創建了三個不同的分配器程序并重載了dispatch方法， 我們在每個dispatch方法中以不同的方式執行Runnable塊，也就是一個簡單的線程，這個異步線程是使用RxJava實現，而Android主線程是使用Handler完成。
如果我們用這些分配器程序執行我們的函數，我們會得到這些日志
E / Thread Running：Thread-582
E / Thread Running：RxCachedThreadScheduler-1
E / Thread Running：main
這真的顯示了協同程序的強大功能，因為Coroutines只是語言語法，它們與運行它們的平臺無關。不同線程的職責分配只需開發人員使用一組函數就能實現，他可以在Rx線程或主線程上執行他喜歡的協同程序。
協同程序就像空的冰淇淋甜筒，你可以選擇你想要冰淇淋的填入。
無線程Thread-less異步
編寫異步代碼傳統上被認為是一種線程工作，其實并不總是如此，讓我們看看如何使用Coroutines解決這個問題
讓我們看看一系列函數執行
mySmallFunction1() myHeavyFunction() // Takes 3 seconds to executemySmallFunction2()//Order運行順序E/mySmallFunction1 running on: mainE/myHeavyFunction running on: mainE/mySmallFunction2 running on: main
現在因為myHeavyFunction()函數需要很長時間才能執行，所以我們可能想要異步執行它。
mySmallFunction1()thread { myHeavyFunction() } //Execution in a separate thread.mySmallFunction2()//Order順序E/mySmallFunction1 running on: mainE/mySmallFunction2 running on: mainE/myHeavyFunction running on: Thread-697這里我們將myHeavyFunction()遷移到一個單獨的線程并異步執行它，但是如果我們這樣做：
mySmallFunction1()launch(UI) { myHeavyFunction() }mySmallFunction2()//OrderE/mySmallFunction1 running on: mainE/mySmallFunction2 running on: mainE/myHeavyFunction running on: main這里我們在主線程上運行的Coroutine上下文（UI：由coroutine-android庫提供）中執行重量函數，執行仍然是異步的，因為Coroutines是通過暫停這部分函數處理，但函數執行仍然發生在主線程上，而不創建額外的線程。
實戰協程
在大多數情況下，我們需要來自一個異步執行的回調，這樣我們就可以通過回調函數來更新UI等，這里就可以使用Deferred語法：
Deferred本身繼承擴展了Job，但增加一個額外的功能，它可以在函數完成執行后返回未來的值。
讓我們看看我們在這里做了什么:
fun <T> asyncExecutor(block: () -> T, response: (T) -> Unit): Job { return launch(UI) { val deferred = async(singleThreadDispatcher) { block.invoke() } response.invoke(deferred.await()) }}讓我們分析一下：
1. launch（UI）使用Android的UI所在的線程上下文創建一個協同Job。
2. 我們通過async異步創建了另一個協同程序，其中包含我們需要調用的函數，唯一的區別是：這個協程返回一個Deferred值，async是協程庫的一部分。
3. 我們調用await（）函數來捕獲Deferred的未來值。這是在UI所在線程上下文中捕獲的。
總而言之，我們創建了一個異步執行程序，我們可以在其中傳遞函數并讓它們異步執行，然后將值返回給UI線程。
現在我們在哪里可以使用它 ? 數據庫查詢
// Insert into DB without callbacksingleThreadAsync { movieDataBase.movieDao().insert(movieObject) }// Get List of movies from DB and filter itasyncExecutor({ movieDataBase.movieDao().getAll() }, { movieList -> movieList .filter { it.isFavorite } .map { it.originalLanguage = "English" } //Dispatch to UI})我們將插入到DB的請求變成了一個發射就可以忘記不用等待結果的異步請求，這是使用singleThreadAsync實現的 。
當我們從DB檢索數據時，我們可以使用我們的asyncExecutor來檢索對象列表，然后使用Collection Framework中的運算符發揮所有kotlin優點啦！
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對武林網的支持。
新聞熱點
疑難解答
