Go語言學習筆記（七）殺手鐧 Goroutine + Channel

来源:http://www.cnblogs.com/suoning/archive/2017/08/08/7237444.html
-Advertisement-
Play Games

加 Golang學習 QQ群共同學習進步成家立業工作 ^-^ 群號：96933959 Goroutine Go語言的主要的功能在於令人簡易使用的並行設計，這個方法叫做Goroutine，通過Goroutine能夠讓你的程式以非同步的方式運行，而不需要擔心一個函數導致程式中斷，因此Go語言也非常地適合網 ...


加 Golang學習 QQ群共同學習進步成家立業工作 ^-^ 群號：96933959

Goroutine

Go語言的主要的功能在於令人簡易使用的並行設計，這個方法叫做Goroutine，通過Goroutine能夠讓你的程式以非同步的方式運行，而不需要擔心一個函數導致程式中斷，因此Go語言也非常地適合網路服務。

我們通過go讓其中一個函數同步運行，如此就不需要等待該函數運行完後才能運行下一個函數。

func main() {
    // 通過 `go`，我們可以把這個函數非同步執行，這樣就不會阻塞往下執行。
    go loop()
    // 執行 Other
}

Goroutine是類似線程的概念（但Goroutine並不是線程）。線程屬於系統層面，通常來說創建一個新的線程會消耗較多的資源且管理不易。而 Goroutine就像輕量級的線程，但我們稱其為併發，一個Go程式可以運行超過數萬個 Goroutine，並且這些性能都是原生級的，隨時都能夠關閉、結束。一個核心裡面可以有多個Goroutine，通過GOMAXPROCS參數你能夠限制Gorotuine可以占用幾個系統線程來避免失控。

在內置的官方包中也不時能夠看見Goroutine的應用，像是net/http中用來監聽網路服務的函數實際上是創建一個不斷運行迴圈的Goroutine。

 

設置同時執行的cpu數（GOMAXPROCS）

GOMAXPROCS 在調度程式優化後會去掉，預設用系統所有資源。

func main() {
    num := runtime.NumCPU()    //本地機器的邏輯CPU個數
    runtime.GOMAXPROCS(num)    //設置可同時執行的最大CPU數，並返回先前的設置
    fmt.Println(num)
}

 

Goroutine中使用recover

應用場景，如果某個goroutine panic了，而且這個goroutine裡面沒有捕獲(recover)，那麼整個進程就會掛掉。所以，好的習慣是每當go產生一個goroutine，就需要寫下recover。

var (
    domainSyncChan = make(chan int, 10)
)

func domainPut(num int) {
    defer func() {
        err := recover()
        if err != nil {
            fmt.Println("error to chan put.")
        }
    }()
    domainSyncChan <- num
    
    panic("error....")
}

func main() {
    for i := 0; i < 10; i++ {
        domainName := i
        go domainPut(domainName)
    }
    time.Sleep(time.Second * 2)
}

 

Goroutine 慄子

package main

import (
    "fmt"
    "sync"
    "time"
)

var (
    m    = make(map[int]uint64)
    lock sync.Mutex //申明一個互斥鎖
)

type task struct {
    n int
}

func calc(t *task) {
    defer func() {
        err := recover()
        if err != nil {
            fmt.Println("error...")
            return
        }
    }()

    var sum uint64
    sum = 1
    for i := 1; i < t.n; i++ {
        sum *= uint64(i)
    }

    lock.Lock() //寫全局數據加互斥鎖
    m[t.n] = sum
    lock.Unlock() //解鎖
}

func main() {
    for i := 0; i < 10; i++ {
        t := &task{n: i}
        go calc(t) // Goroutine來執行任務
    }

    time.Sleep(time.Second) // Goroutine非同步，所以等一秒到任務完成

    lock.Lock() //讀全局數據加鎖
    for k, v := range m {
        fmt.Printf("%d! = %v\n", k, v)
    }
    fmt.Println(len(m))
    lock.Unlock() //解鎖
}

 

Channel

channel，管道、隊列，先進先出，用來非同步傳遞數據。channel加上goroutine，就形成了一種既簡單又強大的請求處理模型，使高併發和線程同步之間代碼的編寫變得異常簡單。

線程安全，多個goroutine同時訪問，不需要加鎖。

channel是有類型的，一個整數的channel只能存放整數。

channel使用

//chan申明
var userChan chan interface{}          // chan裡面放interface類型
userChan = make(chan interface{}, 10)  // make初始化，大小為10

var readOnlyChan <-chan int            // 只讀chan
var writeOnlyChan chan<- int           // 只寫chan
//chan放取數據
userChan <- "nick"
name := <- userChan
name, ok := <- userChan
//關閉chan
intChan := make(chan int, 1)
intChan <- 9
close(intChan)
// range chan
intChan := make(chan int, 10)
for i := 0; i < 10; i++ {
    intChan <- i
}
close(intChan)

for v := range intChan {
    fmt.Println(v)
}

  

放入chan數據個數超過初始化指定大小會怎樣？

userChan := make(chan interface{})
userChan <- "nick"
// 錯誤！fatal error: all goroutines are asleep - deadlock!
// 開啟race會一直阻塞

開啟一個goroutine來放入初始化未指定大小的chan不會報錯。

即放即走，在等放入時有來拿數據的，就直接拿走。

userChan := make(chan interface{})
go func() {
    userChan <- "nick"
}()
name := <- userChan
userChan := make(chan interface{})
go func() {
    for {
        userChan <- "nick"
    }
}()
for {
    name := <- userChan
    fmt.Println(name)
    time.Sleep(time.Millisecond)
}

 

chan關閉與不關閉

關閉chan後再放入數據會 panic: send on closed channel。

chan不關閉取超數據的情況會報 deadlock

func main() {
    intChan := make(chan int, 10)

    for i := 0; i < 10; i++ {
        intChan <- i
    }
    for {
        //十次後 fatal error: all goroutines are asleep - deadlock!
        i := <- intChan
        fmt.Println(i)
        time.Sleep(time.Second)
    }
}

chan關閉的情況取超出值為類型預設值，如int為0

func main() {
    intChan := make(chan int, 10)

    for i := 0; i < 10; i++ {
        intChan <- i
    }
    close(intChan)

    for {
        i := <- intChan
        //十次後i值都為0，不報錯
        time.Sleep(time.Second)
        fmt.Println(i)
    }
}

判斷chan是否取完

func main() {
    intChan := make(chan int, 10)

    for i := 0; i < 10; i++ {
        intChan <- i
    }
    close(intChan)

    for {
        i, ok := <- intChan
        if !ok {
            fmt.Println("channel is close.")
            return
        }
        fmt.Println(i)
    }
}

 

channel 慄子

慄子一

func sendData(ch chan<- string) {
    ch <- "go"
    ch <- "java"
    ch <- "c"
    ch <- "c++"
    ch <- "python"
    close(ch)
}

func getData(ch <-chan string, chColse chan bool) {
    for {
        str, ok := <-ch
        if !ok {
            fmt.Println("chan is close.")
            break
        }
        fmt.Println(str)
    }
    chColse <- true
}

func main() {
    ch := make(chan string, 10)
    chColse := make(chan bool, 1)
    go sendData(ch)
    go getData(ch, chColse)
    <-chColse
    close(chColse)
}

 

慄子二：interface類型chan，取出後轉化為對應類型。

type user struct {
    Name string
}

func main() {
    userChan := make(chan interface{}, 1)

    u := user{Name: "nick"}
    userChan <- &u
    close(userChan)

    var u1 interface{}
    u1 = <-userChan

    var u2 *user
    u2, ok := u1.(*user)
    if !ok {
        fmt.Println("cant not convert.")
        return
    }
    fmt.Println(u2)
}

 

channel 超時處理

利用select來處理chan超時。

for {
    select {
    case v := <-chan1:
        fmt.Println(v)
    case v := <-chan2:
        fmt.Println(v)
    default:
        time.Sleep(time.Second)
        fmt.Println("timeout...")
    }
}

time.After()定時器來做處理。

在time.After()計時器觸發之前，底層計時器不會被垃圾收集器回收。

select {
case m := <-c:
    handle(m)
case <-time.After(5 * time.Minute):
    fmt.Println("timed out")
}
    t := time.NewTicker(time.Second)
    fmt.Println(t)
    for v := range t.C {
        fmt.Println(v)
    }
    t.Stop()
定時器慄子

 

Goroutine+Channel 慄子

慄子一

多個goroutine處理任務；

等待一組channel的返回結果。

func calc(taskChan, resChan chan int, exitChan chan bool) {
    defer func() {
        err := recover()
        if err != nil {
            fmt.Println("error...")
            return 
        }
    }()
    
    for v := range taskChan {
        // 任務處理邏輯
        flag := true
        for i := 2; i < v; i++ {
            if v%i == 0 {
                flag = false
                break
            }
        }
        if flag {
            //結果進chan
            resChan <- v
        }
    }
    //處理完進退出chan
    exitChan <- true
}

func main() {
    //任務chan
    intChan := make(chan int, 1000)
    //結果chan
    resChan := make(chan int, 1000)
    //退出chan
    exitChan := make(chan bool, 8)

    go func() {
        for i := 0; i < 1000; i++ {
            intChan <- i
        }
        close(intChan)
    }()

    //啟動8個goroutine做任務
    for i := 0; i < 8; i++ {
        go calc(intChan, resChan, exitChan)
    }

    go func() {
        //等所有goroutine結束
        for i := 0; i < 8; i++ {
            <-exitChan
        }
        close(resChan)
        close(exitChan)
    }()

    for v := range resChan {
        fmt.Println(v)
    }
}

 

慄子二

等待一組channel的返回結果 sync.WaitGroup 的解決方法。

WaitGroup用於等待一組線程的結束。父線程調用Add方法來設定應等待的線程的數量。每個被等待的線程在結束時應調用Done方法。同時，主線程里可以調用Wait方法阻塞至所有線程結束。

func merge(cs <-chan int) <-chan int {
    var wg sync.WaitGroup
    out := make(chan int)

    output := func(c <-chan int) {
        for n := range c {
            out <- n
        }
        wg.Done()
    }
    wg.Add(len(cs))

    for _, c := range cs {
        go output(c)
    }

    go func() {
        wg.Wait()
        close(out)
    }()
    return out
}

 


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

-Advertisement-
Play Games
更多相關文章
  • struts2中的s標簽
    1 那就從簡單的標簽說起吧！1.x中常用的標簽只有4中html、bean、logic、tiles 2 3 而struts2.0里的標簽卻沒有分類，只用在jsp頭文件加上 4 5 6 就能使用struts2.0的標簽庫 7 8 9 下麵就介紹每個標簽的具體應用實例說明：按字母排列 10 11 12 A... ...
  • 一些輪詢操作
    (1) dictionary 用 method item()可以同時得到key和value (2) 用emurate輪詢List可以同時得到索引和值(3) 假如需要同時輪詢兩個或多個序列，可以使用zip() (4) 如果需要反向輪詢，可以用reversed ...
  • Java中如何使用線程
    首先瞭解線程的狀態轉換圖： 在Java中一個類要當做線程來使用有兩種方法： 1）繼承Thread類，並重寫run函數 2）實現Runable介面，並重寫run函數 Java是單繼承的，但某些情況下一個類可能已經繼承了某個父類，則不能再繼承Thread類創建線程，只能用第二種。 下麵是針對同一問題“編 ...
  • js加密後臺加密解密以及驗證碼
    該文檔為轉載內容： 加密解密 1 前端js加密概述 2 前後端加密解密 21 引用的js加密庫 22 js加密解密 23 Java端加密解密PKCS5Padding與js的Pkcs7一致 驗證碼 1 概述 2 驗證碼生成器 3 控制器使用驗證碼 如 CodeController 應用 1 login ...
  • 簡單的sequence unpacking
    t = (1, 2, ‘hl’)x, y, z = t上述方法可用於任何sequence ...
  • 非IOC方式獲取web對象
    package com.hd.action; import java.util.Map; import javax.servlet.ServletContext; import javax.servlet.http.HttpServlet; import javax.servlet.http.Htt... ...
  • BZOJ 1568: [JSOI2008]Blue Mary開公司(超哥線段樹)
    1568: [JSOI2008]Blue Mary開公司 Description Input 第一行 ：一個整數N ，表示方案和詢問的總數。 接下來N行，每行開頭一個單詞“Query”或“Project”。 若單詞為Query，則後接一個整數T，表示Blue Mary詢問第T天的最大收益。 若單詞為 ...
  • .PHONY makefile中的偽目標
    我的理解： 拿clean舉例，如果make完成後，自己另外定義一個名叫clean的文件，再執行make clean時，將不會執行rm命令。 為了避免出現這個問題，需要.PHONY: clean 所謂偽目標就是這樣一個目標，它不代表一個真正的文件名，在執行make時可以指定這個目標來執行其所在規則定義 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 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 ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類