Go语言并发编程指南：掌握Goroutine与Channel-Golang-PHP中文网

Go语言并发编程指南：掌握Goroutine与Channel

尼克

发布： 2025-06-26 13:40:02

原创

475人浏览过

goroutine和channel是go并发编程的核心。1.goroutine是轻量级线程，通过go关键字创建，并使用sync.waitgroup进行同步；2.channel用于goroutine之间的通信，分为带缓冲和不带缓冲两种类型，前者允许发送和接收操作在缓冲区未满或非空时继续执行，后者要求发送和接收必须同时准备好；3.避免goroutine泄露的方法包括使用select语句处理超时、利用context包控制生命周期以及确保channel被关闭；4.select语句支持多路复用，可监听多个channel并选择最先准备好的分支执行；5.并发错误可通过channel传递、使用sync.errgroup统一处理或在必要时结合panic和recover机制来管理，从而构建高效可靠的并发程序。

Go语言并发编程指南：掌握Goroutine与Channel

Go语言并发编程的核心在于Goroutine和Channel，理解并熟练运用它们，可以构建高效、可靠的并发程序。本文将深入探讨Goroutine与Channel的使用，并提供一些实用的技巧和最佳实践。

Goroutine和Channel是Go并发编程的两大支柱。Goroutine是轻量级线程，Channel是Goroutine之间通信的管道。

Goroutine的创建与管理

Goroutine的创建非常简单，只需在函数调用前加上go关键字即可。

立即学习“go语言免费学习笔记（深入）”；

package main

import (
    "fmt"
    "time"
)

func sayHello(name string) {
    fmt.Println("Hello, " + name + "!")
}

func main() {
    go sayHello("Alice")
    go sayHello("Bob")
    time.Sleep(1 * time.Second) // 确保Goroutine有足够的时间执行
}

登录后复制

这段代码会并发地执行sayHello函数，分别打印"Hello, Alice!"和"Hello, Bob!"。需要注意的是，main函数需要等待一段时间，以确保Goroutine有足够的时间执行。可以使用time.Sleep，但更好的方式是使用sync.WaitGroup来同步Goroutine。

package main

import (
    "fmt"
    "sync"
)

func sayHello(name string, wg *sync.WaitGroup) {
    defer wg.Done() // Goroutine完成时减少计数器
    fmt.Println("Hello, " + name + "!")
}

func main() {
    var wg sync.WaitGroup
    wg.Add(2) // 设置等待的Goroutine数量
    go sayHello("Alice", &wg)
    go sayHello("Bob", &wg)
    wg.Wait() // 等待所有Goroutine完成
}

登录后复制

sync.WaitGroup提供了一种更可靠的方式来等待Goroutine完成。wg.Add(2)设置需要等待的Goroutine数量，wg.Done()在每个Goroutine完成时减少计数器，wg.Wait()会阻塞直到计数器变为0。

Channel的使用与类型

Channel是Goroutine之间通信的管道，它可以传递各种类型的数据。Channel有两种类型：带缓冲和不带缓冲。

不带缓冲的Channel

不带缓冲的Channel要求发送和接收操作必须同时准备好，否则会阻塞。

package main

import (
    "fmt"
)

func main() {
    ch := make(chan string)

    go func() {
        ch <- "Hello, Channel!" // 发送数据
    }()

    msg := <-ch // 接收数据
    fmt.Println(msg)
}

登录后复制

在这个例子中，发送操作ch <- "Hello, Channel!"会阻塞，直到有另一个Goroutine准备好接收数据。同样，接收操作msg := <-ch也会阻塞，直到有数据发送到Channel。

带缓冲的Channel

带缓冲的Channel允许发送操作在缓冲区未满时继续执行，接收操作在缓冲区非空时继续执行。

GPTKit

一个AI文本生成检测工具

108

查看详情

package main

import (
    "fmt"
)

func main() {
    ch := make(chan string, 2) // 创建一个缓冲区大小为2的Channel

    ch <- "Message 1"
    ch <- "Message 2"

    fmt.Println(<-ch)
    fmt.Println(<-ch)
}

登录后复制

在这个例子中，发送操作可以立即执行，因为缓冲区大小为2。只有当缓冲区满时，发送操作才会阻塞。

如何避免Goroutine泄露？

Goroutine泄露是指Goroutine一直处于运行状态，无法退出，导致资源浪费。以下是一些避免Goroutine泄露的方法：

使用select语句处理超时：当从Channel接收数据时，可以使用select语句设置超时，避免无限期等待。

package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan string)

    go func() {
        time.Sleep(5 * time.Second) // 模拟长时间操作
        ch <- "Result"
    }()

    select {
    case msg := <-ch:
        fmt.Println("Received:", msg)
    case <-time.After(2 * time.Second):
        fmt.Println("Timeout!")
    }
}

登录后复制

使用context包控制Goroutine的生命周期：context包提供了一种优雅的方式来取消Goroutine。

package main

import (
    "context"
    "fmt"
    "time"
)

func worker(ctx context.Context) {
    for {
        select {
        case <-ctx.Done():
            fmt.Println("Worker stopped")
            return
        default:
            fmt.Println("Working...")
            time.Sleep(1 * time.Second)
        }
    }
}

func main() {
    ctx, cancel := context.WithCancel(context.Background())
    go worker(ctx)

    time.Sleep(3 * time.Second)
    cancel() // 取消Goroutine
    time.Sleep(1 * time.Second) // 等待Goroutine退出
}

登录后复制

确保所有Channel最终都会被关闭或处理：如果Channel不再需要，应该关闭它。接收者应该检查Channel是否已关闭，并优雅地退出。

如何选择带缓冲还是不带缓冲的Channel？

选择带缓冲还是不带缓冲的Channel取决于具体的应用场景。

不带缓冲的Channel：适用于需要同步的场景，发送者和接收者必须同时准备好，可以保证数据的及时传递。
带缓冲的Channel：适用于发送者和接收者速度不匹配的场景，可以缓解生产者和消费者之间的压力。

一般来说，如果无法确定缓冲大小，最好使用不带缓冲的Channel，因为它更安全，可以避免死锁。

如何使用`select`语句进行多路复用？

select语句允许同时监听多个Channel，并在其中一个Channel准备好时执行相应的操作。

package main

import (
    "fmt"
    "time"
)

func main() {
    ch1 := make(chan string)
    ch2 := make(chan string)

    go func() {
        time.Sleep(2 * time.Second)
        ch1 <- "Message from channel 1"
    }()

    go func() {
        time.Sleep(1 * time.Second)
        ch2 <- "Message from channel 2"
    }()

    select {
    case msg := <-ch1:
        fmt.Println("Received from ch1:", msg)
    case msg := <-ch2:
        fmt.Println("Received from ch2:", msg)
    }
}

登录后复制

在这个例子中，select语句会等待ch1或ch2中的一个Channel准备好。由于ch2更快，所以会先打印"Received from ch2: Message from channel 2"。

select语句还可以与default分支一起使用，实现非阻塞的Channel操作。

package main

import (
    "fmt"
)

func main() {
    ch := make(chan string)

    select {
    case msg := <-ch:
        fmt.Println("Received:", msg)
    default:
        fmt.Println("No message received")
    }
}

登录后复制

由于ch中没有数据，所以会执行default分支，打印"No message received"。

如何处理并发错误？

在并发编程中，错误处理是一个重要的问题。以下是一些处理并发错误的方法：

使用Channel传递错误：可以将错误信息通过Channel传递给其他Goroutine进行处理。

package main

import (
    "fmt"
    "errors"
)

func worker(id int, result chan string, errChan chan error) {
    // 模拟可能出错的操作
    if id%2 == 0 {
        errChan <- errors.New(fmt.Sprintf("Worker %d failed", id))
        return
    }
    result <- fmt.Sprintf("Worker %d succeeded", id)
}

func main() {
    resultChan := make(chan string)
    errChan := make(chan error)

    for i := 0; i < 5; i++ {
        go worker(i, resultChan, errChan)
    }

    for i := 0; i < 5; i++ {
        select {
        case res := <-resultChan:
            fmt.Println("Result:", res)
        case err := <-errChan:
            fmt.Println("Error:", err)
        }
    }
}

登录后复制

使用sync.ErrGroup：sync.ErrGroup可以等待一组Goroutine完成，并返回第一个非nil的错误。

package main

import (
    "fmt"
    "sync"
    "errors"
    "context"
)

func main() {
    var eg sync.WaitGroup
    var err error
    ctx, cancel := context.WithCancel(context.Background())

    results := make(chan string, 5)

    for i := 0; i < 5; i++ {
        i := i // Capture i for the closure
        eg.Add(1)
        go func() {
            defer eg.Done()
            select {
            case <-ctx.Done():
                return
            default:
                if i%2 == 0 {
                    err = errors.New(fmt.Sprintf("Worker %d failed", i))
                    fmt.Println("Worker error:", err)
                    cancel() // Cancel other workers on error
                    return
                }
                results <- fmt.Sprintf("Worker %d succeeded", i)
                fmt.Println("Worker success:", i)
            }
        }()
    }

    eg.Wait()
    close(results)

    if err != nil {
        fmt.Println("An error occurred:", err)
    } else {
        for res := range results {
            fmt.Println("Result:", res)
        }
    }
}

登录后复制