Go：再次温故并发编程 1 Goroutines：轻量级线

发表于

Go 语言自诞生之初便以其原生的并发编程支持作为主要卖点之一。通过轻量级的线程（goroutines）和强大的通信机制（channels），Go 不仅提供了一种高效处理并行任务的方法，还简化了并发控制和状态管理的复杂性。本文将详细介绍 Go 中的并发机制，探讨 goroutine 的使用技巧，channel 的各种操作模式，以及如何通过这些工具实现高效的并发程序。

Screenshot 2024-04-21 154137.png

  1. Goroutines：轻量级线程

Goroutines 是 Go 中实现并发的核心。与传统的线程相比，goroutines 是由 Go 运行时管理的，拥有更小的堆栈内存（通常几 KB），且创建和销毁的开销小，允许程序同时运行成千上万的 goroutines。

1.1 启动与运行 Goroutine

在 Go 中，启动一个 goroutine 非常简单。我们只需要在函数调用前加上 go 关键字。例如：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
go复制代码package main

import (
    "fmt"
    "time"
)

func say(s string) {
    for i := 0; i < 5; i++ {
        time.Sleep(100 * time.Millisecond)
        fmt.Println(s)
    }
}

func main() {
    go say("world")
    say("hello")
}

在这个例子中，main 函数中的 go say(“world”) 启动了一个新的 goroutine。这意味着 say(“world”) 与 say(“hello”) 将并发执行。

1.2 Goroutine 的调度

Go 使用了基于 M:N 调度模型（多个 goroutines 可以在多个 OS 线程上运行）。Go 调度器在运行时分配 goroutines 到可用的逻辑处理器，然后将这些逻辑处理器绑定到单个 OS 线程。

  1. Channels：协程间的通信

Channels 是 Go 中用于在 goroutines 之间安全传递数据的机制。通过使用 channels，开发者可以避免传统并发程序中常见的竞态条件和锁问题。

2.1 创建和使用 Channel

我们可以使用 make 函数创建一个新的 channel：

1
go复制代码ch := make(chan int)

Goroutines 通过 channel 发送和接收数据，操作符为 <-。例如：

1
2
go复制代码ch <- v // 发送 v 到 channel ch
v := <-ch // 从 ch 接收数据并赋值给 v

2.2 Channel 的阻塞行为

Channels 的重要特性之一是它们的阻塞行为。如果一个 goroutine 试图从一个空的 channel 接收数据，它会阻塞，直到有数据可读。同样，如果一个 goroutine 试图向一个满的（或未准备好的接收者）channel 发送数据，它也会阻塞，直到数据被读取。

  1. 实战案例：并发的 Web 爬虫

考虑一个简单的 Web 爬虫，它使用 goroutines 并发地抓取网页，并通过一个共享的 channel 传递数据：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
go复制代码package main

import (
    "fmt"
    "net/http"
    "time"
)

func fetch(url string, ch chan<- string) {
    start := time.Now()
    resp, err := http.Get(url)
    if err != nil {
        ch <- fmt.Sprintf("error: %s", err)
        return
    }
    ch <- fmt.Sprintf("%s, %s, %dms", url, resp.Status, time.Since(start).Milliseconds())
}

func main() {
    urls := []string{
        "https://www.google.com",
        "https://www.baidu.com",
        "https://www.amazon.com",
    }

    ch := make(chan string)
    for _, url := range urls {
        go fetch(url, ch)
    }

    for range urls {
        fmt.Println(<-ch)
    }
}

在这里插入图片描述

总结

通过 goroutines 和 channels，Go 为并发编程提供了强大而简洁的工具。这些特性使得开发并行程序和管理复杂的并发状态变得更加容易。随着对这些机制的深入了解，我们将能够更有效地利用现代多核硬件，编写高效、可靠的 Go 程序。

本文转载自: 掘金

开发者博客 – 和开发相关的 这里全都有

0%