首頁 > 後端開發 > Golang > golang函數如何與goroutine互動?

golang函數如何與goroutine互動?

WBOY
發布: 2024-05-04 12:24:02
原創
640 人瀏覽過

Go 函數透過 channel 傳遞資料、wait group 或 channel 控制執行流程、mutex 或 channel 同步任務來與 Goroutine 互動:傳遞資料:使用 channel 作為 FIFO 佇列,從函數向協程傳送和接收值。控制執行流程:使用 wait group 等待協程完成執行,或使用 channel 通知協程執行特定操作。同步任務:使用 mutex 或 channel 對並發存取的資源進行同步,確保一次只有一個協程存取資源。

golang函數如何與goroutine互動?

Go 函數如何與 Goroutine 互動?

在 Go 中,Goroutine 是並發執行的輕量級執行緒。它們允許您並行運行程式碼,提高應用程式效能。函數可以與協程互動以控制執行流程、傳遞資料和同步任務。

傳遞資料

可以透過 channel 將資料從函數傳遞到協程。 Channel 是一個 FIFO(先進先出)佇列,允許協程從函數接收和傳送值。以下範例展示如何使用 channel:

package main

import "fmt"

func sendData(ch chan<- int) {
    for i := 0; i < 10; i++ {
        ch <- i
    }
    close(ch)
}

func receiveData(ch <-chan int) {
    for {
        data, ok := <-ch
        if !ok {
            return
        }
        fmt.Println("Received:", data)
    }
}

func main() {
    ch := make(chan int)
    go sendData(ch)
    receiveData(ch)
}
登入後複製

控制執行流程

可以使用 wait group 或 channel 控制協程的執行流程。 Wait group 允許您等待所有協程完成執行,而 channel 可用於通知協程執行特定操作。以下範例展示如何使用 wait group:

package main

import (
    "fmt"
    "sync"
)

var wg sync.WaitGroup

func task(i int) {
    fmt.Println("Task", i)
    wg.Done()
}

func main() {
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go task(i)
    }
    wg.Wait()
}
登入後複製

同步任務

可以透過 mutex 或 channel 對並發存取的資源進行同步。 Mutex 互斥鎖,一次允許一個協程存取資源。 Channel 可用於阻塞協程,直到資源可用。以下範例展示如何使用 mutex:

package main

import (
    "fmt"
    "sync"
)

var mutex sync.Mutex

func task(data string) {
    mutex.Lock()
    fmt.Println(data)
    mutex.Unlock()
}

func main() {
    for i := 0; i < 10; i++ {
        go task(fmt.Sprintf("Task %d", i))
    }
}
登入後複製

以上是golang函數如何與goroutine互動?的詳細內容。更多資訊請關注PHP中文網其他相關文章!

相關標籤:
來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板