当前位置:
首页
文章
后端
详情

Go语言并发编程的核心 —— GMP调度模型

在Go语言中,GMP调度模型是实现并发的重要手段之一。GMP调度模型的核心思想是将M(Machine)、G(Goroutine)和P(Processor)三个概念分离开来,通过调度器来协调它们之间的关系,从而实现高效的并发。

M(Machine)

M代表着操作系统中的线程,它是Go语言中的执行单位。在程序启动时,Go语言会创建一定数量的M,每个M都会绑定一个P。M的数量默认是CPU核心数,但是可以通过GOMAXPROCS环境变量来设置。

G(Goroutine)

Goroutine是Go语言中的轻量级线程,它可以与M一起调度执行。在程序中,我们可以通过关键字go来启动一个Goroutine,例如:

go func() {
    // 处理业务逻辑
}()

在上面的例子中,我们使用go关键字启动了一个Goroutine,并在其中执行业务逻辑。需要注意的是,Goroutine是由Go语言的运行时(runtime)进行调度的,而不是由操作系统进行调度,因此它具有轻量级、高效等特点。

P(Processor)

Processor是Go语言中的处理器,它负责将Goroutine分配给M执行。每个M都会绑定一个P,而P的数量可以通过runtime.NumCPU()来获取(不同于M的数量)。

调度器

调度器是GMP调度模型的核心,它负责将Goroutine分配给M执行,并在M的数量不足时创建新的M。调度器还可以将M从一个P转移到另一个P,以达到负载均衡的目的。

调度器的实现方式比较复杂,但是它的工作原理可以简单概括如下:

  • 当一个Goroutine被启动时,它会被放入一个全局的运行队列中(称为全局队列)。
  • 当一个M空闲时,它会从全局队列中获取一个Goroutine,并开始执行它。
  • 当一个Goroutine阻塞时,它会被放入一个本地的等待队列中(称为本地队列)。
  • 当一个M中的本地队列为空时,它会从全局队列中获取一批Goroutine,并将它们放入本地队列中。
  • 当一个P中的本地队列为空时,它会从其他P中的本地队列中获取一批Goroutine,并将它们放入本地队列中。
  • 当一个M执行时间过长时,调度器会中断它的执行,并将它的状态保存到一个全局的挂起队列中。下次该M被分配到执行时,它会从挂起队列中恢复状态,并继续执行。
  • 当一个M执行的Goroutine数量达到一定阈值时,调度器会将它的状态保存到一个全局的休眠队列中。下次该M被分配到执行时,它会从休眠队列中恢复状态,并继续执行。

下面我们来看一个简单的示例,它通过启动多个Goroutine来计算斐波那契数列的值:

package main

import "fmt"

func main() {
    for i := 0; i < 10; i++ {
        go func() {
            fmt.Println(fib(40))
        }()
    }
}

func fib(n int) int {
    if n < 2 {
        return n
    }
    return fib(n-1) + fib(n-2)
}

在上面的例子中,我们启动了10个Goroutine,并在其中计算斐波那契数列的值。由于斐波那契数列的计算是CPU密集型的,因此这个程序会利用GMP调度模型来实现高效的并发。

注意事项

在使用GMP调度模型时,需要注意以下几点:

  • 不要在Goroutine中阻塞或者进行长时间的计算,这会导致M被挂起或者休眠,从而影响程序的性能。
  • 不要在Goroutine中访问共享资源时不加锁,这会导致数据竞争,从而引发难以排查的bug。
  • 不要将过多的Goroutine放入全局队列中,这会导致调度器的性能下降,从而影响程序的性能。
  • 不要将过多的M创建出来,这会导致系统资源的浪费,从而影响程序的性能。

免责申明:本站发布的内容(图片、视频和文字)以转载和分享为主,文章观点不代表本站立场,如涉及侵权请联系站长邮箱:xbc-online@qq.com进行反馈,一经查实,将立刻删除涉嫌侵权内容。

同类热门文章

深入了解C++中的new操作符:使用具体实例学习

C++中的new操作符是动态分配内存的主要手段之一。在程序运行时,我们可能需要动态地创建和销毁对象,而new就是为此提供了便利。但是,使用new也常常会引发一些问题,如内存泄漏、空指针等等。因此,本文将通过具体的示例,深入介绍C++中的new操作符,帮助读者更好地掌握其使用。


深入了解C++中的new操作符:使用具体实例学习

怎么用Java反射获取包下所有类? 详细代码实例操作

Java的反射机制就是在运行状态下,对于任何一个类,它能知道这个类的所有属性和方法;对于任何一个对象,都能调用这个对象的任意一个方法。本篇文章将通过具体的代码示例,展示如何通过Java反射来获取包下的所有类。


怎么用Java反射获取包下所有类? 详细代码实例操作

员工线上学习考试系统

有点播,直播,在线支付,三级分销等功能,可以对学员学习情况的监督监控,有源码,可二次开发。支持外网和局域网私有化部署,经过测试源码完整可用!1、视频点播:视频播放,图文资料,课件下载,章节试学,限时免

员工线上学习考试系统

了解Java中的volati关键字的作用 以及具体使用方法

本篇文章将和大家分享一下Java当中的volatile关键字,下面将为各位小伙伴讲述volatile关键字的作用以及它的具体使用方法。


了解Java中的volati关键字的作用 以及具体使用方法

Java Map 所有的值转为String类型

可以使用 Java 8 中的 Map.replaceAll() 方法将所有的值转为 String 类型: 上面的代码会将 map 中所有的值都转为 String 类型。 HashMap 是 Java

Java Map 所有的值转为String类型