设为首页 加入收藏

TOP

Go协程揭秘:轻量、并发与性能的完美结合(一)
2023-09-23 15:43:48 】 浏览:303
Tags:程揭秘 轻量 能的完

Go协程为并发编程提供了强大的工具,结合轻量级、高效的特点,为开发者带来了独特的编程体验。本文深入探讨了Go协程的基本原理、同步机制、高级用法及其性能与最佳实践,旨在为读者提供全面、深入的理解和应用指导。

关注公众号【TechLeadCloud】,分享互联网架构、云服务技术的全维度知识。作者拥有10+年互联网服务架构、AI产品研发经验、团队管理经验,同济本复旦硕,复旦机器人智能实验室成员,阿里云认证的资深架构师,项目管理专业人士,上亿营收AI产品研发负责人。

file

1. Go协程简介

Go协程(goroutine)是Go语言中的并发执行单元,它比传统的线程轻量得多,并且是Go语言并发模型中的核心组成部分。在Go中,你可以同时运行成千上万的goroutine,而不用担心常规操作系统线程带来的开销。

什么是Go协程?

Go协程是与其他函数或方法并行运行的函数或方法。你可以认为它类似于轻量级的线程。其主要优势在于它的启动和停止开销非常小,相比于传统的线程来说,可以更有效地实现并发。

package main

import (
    "fmt"
    "time"
)

func sayHello() {
    for i := 0; i < 5; i++ {
        time.Sleep(100 * time.Millisecond)
        fmt.Println("Hello!")
    }
}

func main() {
    go sayHello() // 启动一个Go协程
    for i := 0; i < 5; i++ {
        time.Sleep(150 * time.Millisecond)
        fmt.Println("Hi!")
    }
}

输出:

Hi!
Hello!
Hi!
Hello!
Hello!
Hi!
Hello!
Hi!
Hello!

处理过程:
在上面的代码中,我们定义了一个sayHello函数,它在一个循环中打印“Hello!”五次。在main函数中,我们使用go关键字启动了sayHello作为一个goroutine。此后,我们又在main中打印“Hi!”五次。因为sayHello是一个goroutine,所以它会与main中的循环并行执行。因此,输出中“Hello!”和“Hi!”的打印顺序可能会变化。

Go协程与线程的比较

  1. 启动开销:Go协程的启动开销远小于线程。因此,你可以轻松启动成千上万个goroutine。
  2. 内存占用:每个Go协程的堆栈大小开始时很小(通常在几KB),并且可以根据需要增长和缩小,而线程通常需要固定的、较大的堆栈内存(通常为1MB或更多)。
  3. 调度:Go协程是由Go运行时系统而不是操作系统调度的。这意味着Go协程之间的上下文切换开销更小。
  4. 安全性:Go协程为开发者提供了简化的并发模型,配合通道(channels)等同步机制,减少了并发程序中常见的错误。

示例代码:

package main

import (
    "fmt"
    "time"
)

func worker(id int, ch chan int) {
    for {
        fmt.Printf("Worker %d received data: %d\n", id, <-ch)
    }
}

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

    for i := 0; i < 3; i++ {
        go worker(i, ch) // 启动三个Go协程
    }

    for i := 0; i < 10; i++ {
        ch <- i
        time.Sleep(100 * time.Millisecond)
    }
}

输出:

Worker 0 received data: 0
Worker 1 received data: 1
Worker 2 received data: 2
Worker 0 received data: 3
...

处理过程:
在这个示例中,我们启动了三个工作goroutine来从同一个通道接收数据。在main函数中,我们发送数据到通道。每当通道中有数据时,其中一个工作goroutine会接收并处理它。由于goroutines是并发运行的,所以哪个goroutine接收数据是不确定的。

Go协程的核心优势

  1. 轻量级:如前所述,Go协程的启动开销和内存使用都远远小于传统线程。
  2. 灵活的调度:Go协程是协同调度的,允许用户在适当的时机进行任务切换。
  3. 简化的并发模型:Go提供了多种原语(如通道和锁),使并发编程变得更加简单和安全。

总的来说,Go协程为开发者提供了一个高效、灵活且安全的并发模型。与此同时,Go的标准库提供了丰富的工具和包,进一步简化了并发程序的开发过程。


2. Go协程的基本使用

在Go中,协程是构建并发程序的基础。创建协程非常简单,并且使用go关键字就可以启动。让我们探索一些基本用法和与之相关的示例。

创建并启动Go协程

启动一个Go协程只需使用go关键字,后跟一个函数调用。这个函数即可以是匿名的,也可以是预定义的。

示例代码:

package main

import (
    "fmt"
    "time"
)

func printNumbers() {
    for i := 1; i <= 5; i++ {
        time.Sleep(200 * time.Millisecond)
        fmt.Println(i)
    }
}

func main() {
    go printNumbers()  // 启动一个Go协程
    time.Sleep(1 * time.Second)
    fmt.Println("End of main function")
}

输出:

1
2
3
4
5
End of main function

处理过程:
在这个示例中,我们定义了一个printNumbers函数,它会简单地打印数字1到5。在main函数中,我们使用go关键字启动了这个函数作为一个新的Go协程。主函数与Go协程并行执行。为确保主函数等待Go协程执行完成,我们使主函数休眠了1秒钟。

使用匿名函数创建Go协程

除了启动预定义的函数,你还可以使用匿名函数直接启动Go协程。

示例代码:

package main

import (
    "fmt"
    "time"
)

func main() {
    go func() {
        fmt.Println("This is a goroutine!")
        time.Sleep(500 * time.Millisecond)
    }()
    fmt.Println("This is the main function!")
    time.Sleep(1 * time.Second)
}

输出:

This is the main function!
This is a goroutine!

处理过程:
在这个示例中,我们在main函数中直接使用了一个匿名函数来创建Go协程。在匿名函数中,我们简单地打印了一条消息并使其休眠了500毫秒。主函数先打印其消息,然后等待1秒来确保Go协程有足够的时间完成执行。

Go协程与主函数

值得注意的是,如果主函数(main)结束,所有的Go协程都会被立即终

首页 上一页 1 2 3 4 下一页 尾页 1/4/4
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇每日一库:Prometheus 下一篇Go语法糖

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目