在 go 中管理并发涉及使用 goroutine（并发执行单元）、通道（数据传输机制）和等待组（同步机制）。通过创建 goroutine 并利用通道来安全地传输数据，开发者可以同时执行多个任务。等待组允许等待 goroutine 完成其任务。这些机制的组合使 go 应用程序能够高效、响应迅速地处理并发。

如何在 Golang 中管理并发？

简介

并发是一个重要的编程概念，它允许同时执行多个任务，从而提高效率和响应能力。在 Go 中，并发可以通过 goroutine 来实现，goroutine 是一种轻量级的线程。

Goroutine

Goroutine 是 Go 中的并发执行单元。它们是 Go 运行时自动调度和调度的。创建一个新 goroutine 的语法如下：

go func() {
  // goroutine 的代码在此处执行
}

通道（Channel）

通道是一种通信机制，允许 goroutine 之间安全可靠地传输数据。语法如下：

ch := make(chan Type, bufferSize)

其中 Type 是通道传输的数据类型，bufferSize 是通道的缓冲容量。

等待组（WaitGroup）

等待组是 Go 中的同步机制，它允许等待多个 goroutine 完成各自的任务。语法如下：

var wg sync.WaitGroup

实战案例：并发 Web 服务器

以下是一个使用并发创建 Web 服务器的简单示例：

// demo.go
package main

import (
    "log"
    "net/http"
    "sync"
)

var wg sync.WaitGroup

func main() {
    // 创建一个通道来接收 HTTP 请求
    reqs := make(chan *http.Request)

    // 创建一个 goroutine 来处理请求
    wg.Add(1)
    go func() {
        defer wg.Done()
        for req := range reqs {
            // 处理请求...
        }
    }()

    // 创建 HTTP 服务器
    srv := &http.Server{
        Addr:    ":8080",
        Handler: http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
            reqs <- r
        }),
    }

    // 运行服务器
    log.Fatal(srv.ListenAndServe())
}

结论

通过使用 goroutine、通道和等待组，可以在 Go 中轻松管理并发。这使开发者能够创建高效、响应迅速的应用程序。