Go语言的并发特性详解：Goroutine的原理与应用-Golang-PHP中文网

Go语言的并发特性详解：Goroutine的原理与应用

碧海醫心

发布： 2025-07-28 21:02:12

原创

580人浏览过

go语言的并发特性详解：goroutine的原理与应用

Go语言作为一种并发编程语言，其核心特性在于内置的goroutine机制。Goroutine是一种轻量级线程，允许开发者高效地编写并发程序。本文将深入探讨Go语言的并发模型，介绍goroutine的原理、使用方法以及与其他并发模型的区别，帮助读者理解并掌握Go语言的并发编程。

Go语言的并发模型基于goroutine和channel。Goroutine是Go语言提供的轻量级线程，它比传统的线程更加轻量级，创建和销毁的开销更小。Channel则用于goroutine之间的通信，提供了一种安全、高效的并发编程方式。

Goroutine：轻量级并发的基石

Goroutine本质上是一种协程，由Go运行时（runtime）进行调度。与操作系统线程相比，Goroutine的优势在于：

轻量级： 创建和销毁的开销远小于线程。
高效： 可以在单个线程上运行多个goroutine，提高资源利用率。
并发： Goroutine可以并发执行，充分利用多核CPU的性能。

如何创建和运行Goroutine？

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

使用go关键字即可启动一个新的goroutine。go关键字后面跟一个函数调用，该函数将在一个新的goroutine中异步执行。

package main

import (
    "fmt"
    "time"
)

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

func main() {
    go sayHello("World") // 启动一个新的goroutine
    fmt.Println("Main goroutine")
    time.Sleep(time.Second) // 等待goroutine执行完成
}

登录后复制

在上面的例子中，sayHello("World")将在一个新的goroutine中执行，而fmt.Println("Main goroutine")将在主goroutine中执行。由于goroutine是并发执行的，所以fmt.Println("Main goroutine")可能会在sayHello("World")之前执行。time.Sleep(time.Second)是为了确保主goroutine在程序退出之前等待sayHello goroutine 完成。

Channel：Goroutine之间的通信桥梁

Channel是Go语言中用于goroutine之间通信的管道。通过channel，goroutine可以安全地传递数据，避免竞争条件和死锁等问题。

Channel的类型

PHP高级程序设计模式框架与测试(中文高清PDF版)

享有盛誉的PHP高级教程，Zend Framework核心开发人员力作，深入设计模式、PHP标准库和JSON 。　　今天，PHP已经是无可争议的Web开发主流语言。PHP 5以后，它的面向对象特性也足以与Java和C#相抗衡。然而，讲述PHP高级特性的资料一直缺乏，大大影响了PHP语言的深入应用。　　本书填补了这一空白。它专门针对有一定经验的PHP程序员，详细讲解了对他们最为重要的主题

455

查看详情

Channel分为两种类型：

有缓冲Channel： 可以存储一定数量的数据，发送操作只有在channel未满时才会阻塞，接收操作只有在channel为空时才会阻塞。
无缓冲Channel： 发送和接收操作必须同时准备好才能进行，否则会一直阻塞。

如何创建和使用Channel？

使用make函数可以创建channel。

// 创建一个无缓冲的int类型channel
ch := make(chan int)

// 创建一个缓冲大小为10的int类型channel
bufferedCh := make(chan int, 10)

登录后复制

使用<-操作符可以发送和接收数据。

// 发送数据到channel
ch <- 10

// 从channel接收数据
value := <-ch

登录后复制

示例：使用Channel进行数据传递

package main

import (
    "fmt"
    "time"
)

func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        fmt.Println("worker", id, "processing job", j)
        time.Sleep(time.Second)
        results <- j * 2
    }
}

func main() {
    jobs := make(chan int, 100)
    results := make(chan int, 100)

    // 启动3个worker goroutine
    for w := 1; w <= 3; w++ {
        go worker(w, jobs, results)
    }

    // 发送9个job到jobs channel
    for j := 1; j <= 9; j++ {
        jobs <- j
    }
    close(jobs) // 关闭jobs channel，表示没有更多job了

    // 接收所有结果
    for a := 1; a <= 9; a++ {
        fmt.Println(<-results)
    }
}

登录后复制

在这个例子中，我们创建了两个channel：jobs用于发送job，results用于接收结果。启动了3个worker goroutine，它们从jobs channel接收job，进行处理，并将结果发送到results channel。主goroutine负责发送job和接收结果。close(jobs)用于关闭jobs channel，通知worker goroutine没有更多job了。