kotlin協程小記

来源:https://www.cnblogs.com/tangZH/archive/2022/11/02/16849169.html
-Advertisement-
Play Games

例子一: GlobalScope.launch(Dispatchers.Main) { //開啟子協程 withContext(Dispatchers.IO) { for (i in 0 until 1000) { } Log.d("MainActivityXX", "withContext-> t ...


例子一:

GlobalScope.launch(Dispatchers.Main) {
    //開啟子協程
    withContext(Dispatchers.IO) {
        for (i in 0 until 1000) {
        }
        Log.d("MainActivityXX", "withContext-> thread:" + Thread.currentThread().name)
    }
    Log.d("MainActivityXX", "GlobalScope-> thread:" + Thread.currentThread().name)
}
Log.d("MainActivityXX", "onCreate-> thread:" + Thread.currentThread().name)

列印log:

2022-10-09 20:24:21.100 8371-8371/com.example.xiecheng D/MainActivityXX: onCreate-> thread:main
2022-10-09 20:24:21.131 8371-8412/com.example.xiecheng D/MainActivityXX: withContext-> thread:DefaultDispatcher-worker-1
2022-10-09 20:24:21.258 8371-8371/com.example.xiecheng D/MainActivityXX: GlobalScope-> thread:main

 

例子二:

GlobalScope.launch(Dispatchers.Main) {
    //開啟子協程
    withContext(Dispatchers.IO) {
        for (i in 0 until 1000) {
        }
        Log.d("MainActivityXX", "withContext1-> thread:" + Thread.currentThread().name)
        withContext(Dispatchers.IO) {
            for (i in 0 until 1000) {
            }
            Log.d("MainActivityXX", "withContext2-> thread:" + Thread.currentThread().name)
        }
    }
    withContext(Dispatchers.IO) {
        for (i in 0 until 1000) {
        }
        Log.d("MainActivityXX", "withContext3-> thread:" + Thread.currentThread().name)
    }
    Log.d("MainActivityXX", "GlobalScope-> thread:" + Thread.currentThread().name)
}
Log.d("MainActivityXX", "onCreate-> thread:" + Thread.currentThread().name)

列印log:

onCreate-> thread:main
withContext1-> thread:DefaultDispatcher-worker-1
withContext2-> thread:DefaultDispatcher-worker-1
withContext3-> thread:DefaultDispatcher-worker-1
GlobalScope-> thread:main

主線程開啟一個協程,並不會阻礙主線程的執行,單個協程內部是串列執行的,這裡整一個都是串列執行的是因為withContext是一個掛起函數。

 

GlobalScope.launch(Dispatchers.Main) {
    //開啟子協程
    GlobalScope.launch (Dispatchers.IO) {
        Log.d("MainActivityXX", "withContext-> thread:" + Thread.currentThread().name)
    }
    Log.d("MainActivityXX", "GlobalScope-> thread:" + Thread.currentThread().name)
}

列印log:

GlobalScope-> thread:main
withContext-> thread:DefaultDispatcher-worker-1

 

例子二:

GlobalScope.launch(Dispatchers.Main) {
    //開啟子協程
    withContext(Dispatchers.IO) {
        get()
        Log.d("MainActivityXX", "withContext-> thread:" + Thread.currentThread().name)
    }
    Log.d("MainActivityXX", "GlobalScope-> thread:" + Thread.currentThread().name)
}
suspend fun get() {
Thread {
Thread.sleep(5000)
Log.d("MainActivityXX", "get-> thread:" + Thread.currentThread().name)
}.start()
}
 

列印log:

2022-11-01 20:56:25.220 20058-20100/com.example.xiecheng D/MainActivityXX: withContext-> thread:DefaultDispatcher-worker-1
2022-11-01 20:56:25.264 20058-20058/com.example.xiecheng D/MainActivityXX: GlobalScope-> thread:main
2022-11-01 20:56:30.222 20058-20103/com.example.xiecheng D/MainActivityXX: get-> thread:Thread-8

協程裡面開啟線程,那麼線程不會受協程影響。

 

例子三:

GlobalScope.launch(Dispatchers.Main) {
    fetchDocs()
}

suspend fun fetchDocs() {                             // Dispatchers.Main
    val result = get("https://developer.android.com") // Dispatchers.IO for `get`
    Log.d("MainActivityXX", "fetchDocs-> thread:" + Thread.currentThread().name) 
}
//withContext本身就是掛起函數
suspend fun get(url: String) = withContext (Dispatchers.IO) {
    Log.d("MainActivityXX", "get-> thread:" + Thread.currentThread().name)
}

列印log:

get-> thread:DefaultDispatcher-worker-1
fetchDocs-> thread:main

使用了掛起函數,會先等待get方法執行完再執行下麵得操作。

 

1、掛起函數並不會阻塞其所線上程,這樣就極大地提高了線程的併發靈活度,最大化了線程的利用效率。
當在 ThreadA 上運行的 CoroutineA 調用了delay(1000L)函數指定延遲一秒後再運行,ThreadA 會轉而去執行 CoroutineB,等到一秒後再來繼續執行 CoroutineA

2、withContext本身就是掛起函數。

3、掛起的對象是協程。

4、這個 suspend 關鍵字,既然它並不是真正實現掛起,它其實是一個提醒。函數的創建者對函數的使用者的提醒:我是一個耗時函數,我被我的創建者用掛起的方式放在後臺運行,所以請在協程里調用我。
為什麼 suspend 關鍵字並沒有實際去操作掛起,但 Kotlin 卻把它提供出來?
因為它本來就不是用來操作掛起的。掛起的操作 —— 也就是切線程,依賴的是掛起函數裡面的實際代碼,而不是這個關鍵字。
所以這個關鍵字,只是一個提醒。
所以,創建一個 suspend 函數,為了讓它包含真正掛起的邏輯,要在它內部直接或間接調用 Kotlin 自帶的 suspend 函數,你的這個 suspend 才是有意義的。


5、所以這個 suspend,其實並不是起到把任何把協程掛起,或者說切換線程的作用。真正掛起協程這件事,是 Kotlin 的協程框架幫我們做的。
所以我們想要自己寫一個掛起函數,僅僅只加上 suspend 關鍵字是不行的,還需要函數內部直接或間接地調用到 Kotlin 協程框架自帶的 suspend 函數才行。

6、開發者需要明白,協程是運行於線程上的,一個線程可以運行多個(可以是幾千上萬個)協程。線程的調度行為是由 OS 來操縱的,而協程的調度行為是可以由開發者來指定並由編譯器來實現的。當協程 A 調用 delay(1000L) 函數來指定延遲1秒後再運行時,協程 A 所在的線程只是會轉而去執行協程 B,等到1秒後再把協程 A 加入到可調度隊列里。所以說,線程並不會因為協程的延時而阻塞,這樣可以極大地提高線程的併發靈活度。

 


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

-Advertisement-
Play Games
更多相關文章
  • 前面說到了redis在單機的模式下是可以數據持久化的,但是不可以解決單點失敗的問題,當單台redis伺服器出現問題時,就可能會造成數據的丟失;想要解決這個問題的話我們可以使用Redis的主從模式這也是Redis集群最簡單的實現方式,這篇文章我就來簡單部署一個Redis主從架構,我準備了3台ubunt ...
  • 摘要:本文通過對ETCD服務異常問題分析,代碼展示解決方案。 本文分享自華為雲社區《【實例狀態】GaussDB ETCD服務異常》,作者:酷哥。 首先確認是否是虛擬機、網路故障 虛擬機故障導致ETCD服務異常告警 問題現象 管控面上報etcd服務異常告警,虛擬機發生重啟,熱遷移、冷遷移,HA等動作。 ...
  • 資料庫連接 鏈接資料庫:代表連接資料庫管理系 統 <!--一個應用程式可以對應一個資料庫,一個資料庫管理系統可以管理多個資料庫--> <!--表是用來存儲數據的--> -- 連接資料庫管理系統 mysql -u root -p -- -u 代表用戶 -p代表用密碼登錄 定義資料庫 -- 創建資料庫 ...
  • Redis雖然是一個記憶體級別的緩存程式,也就是redis是使用記憶體進行數據的緩存的,但是其可以將記憶體的數據按照一定的策略保存到硬碟中,這樣的話就可以實現持久保存的目的;目前的話redis支持的兩種不同方式的數據持久化保存機制,分別是RDB和AOF,這兩種方式的話很類似於MySQL資料庫的dump和二 ...
  • PostgreSQL 高可用資料庫的常見搭建方式主要有兩種,邏輯複製和物理複製,上周已經寫過了關於在Windows環境搭建PostgreSQL邏輯複製的教程,這周來記錄一下 物理複製的搭建方法。 首先介紹一下邏輯複製和物理複製的一些基本區別: 物理複製要求多個實例之間大版本一致,並且操作系統平臺一致 ...
  • GreatSQL社區原創內容未經授權不得隨意使用,轉載請聯繫小編並註明來源。 GreatSQL是MySQL的國產分支版本,使用上與MySQL一致。 介紹 從 MySQL 8.0.4 開始,MySQL 預設身份驗證插件從 mysql_native_password 改為 caching_sha2_pa ...
  • 首發微信公眾號:SQL資料庫運維 原文鏈接:https://mp.weixin.qq.com/s?__biz=MzI1NTQyNzg3MQ==&mid=2247485212&idx=1&sn=450e9e94fa709b5eeff0de371c62072b&chksm=ea37536cdd40da7 ...
  • [Android開發學iOS系列] Auto Layout 內容: 介紹什麼是Auto Layout. 基本使用方法 在代碼中寫約束的方法 Auto Layout的原理 尺寸和優先順序 Auto Layout的使用細則 重要的屬性 StackView Layout Guide Performance ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...