Go学习记录之runtime包深入解析

2025-06-10 15:50

本文主要是介绍Go学习记录之runtime包深入解析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

《Go学习记录之runtime包深入解析》Go语言runtime包管理运行时环境,涵盖goroutine调度、内存分配、垃圾回收、类型信息等核心功能,:本文主要介绍Go学习记录之runtime包的...

前言:

先前学习到goroutine协程与channel调节并发同步时,有涉及到关于runtime包管理goroutine运行时的知识点。由于没有接触过,并且出于goroutine的重要性(runtime听着很高大上)的原因,通过多方学习并博客记录。

一、runtime包内容学习

1、作用:

其作用主要是与程序的运行时环境进行交互,提供了一系列函数和变量,用于控制、管理和监视程序的执行:

① Goroutine和并发控制:

runtime包提供了一些函数来管理goroutine,如创建php和销毁goroutine、设置最大可同时执行的CPU数目等,以及用于并发控制的函数,如让出CPU时间片、锁定和解锁goroutine到线程等。

package main

import (
    "fmt"
    "runtime"
    "time"
)

func worker() {
    defer fmt.Println("Worker exiting")
    runtime.Gosched() // 主动让出 CPU
    fmt.Println("Worker running")
}

func main() {
    go worker()
    time.Sleep(time.Second)
    fmt.Println("Number of goroutines:", runtime.NumGoroutine())
}

② 垃圾回收:

Go语言使用自动垃圾回收机制来管理内存,runtime包提供了手动触发垃圾回收、设置垃圾回收的百分比、获取内存统计信息等函数,用于对垃圾回收进行调控和监测。

func main() {
    var m runtime.MemStats
    runtime.ReadMemStats(&m)
    fmt.Printf("Allocated memory: %d bytes\n", m.Alloc)
    runtime.GC() // 手动触发 GC
    runtime.ReadMemStats(&m)
    fmt.Printf("After GC: %d bytes\n", m.Alloc)
}

③ 栈和堆操作:

runtime包提供了函数来获取当前goroutine的堆栈信息、完整的堆栈跟踪,以及对堆栈进行分析和剖析的相关函数。

④ 系统信息和调试:

runtime包提供了获取CPU核心数、CPU性能分析、调试信息等函数,可以用于获取关于系统的一些基本信息和进行程序的调试。

⑤ 错误处理:

runtime包提供了获取调用栈信息、根据PC地址获取函数信息等函数,用于错误处理和调试时追踪错误发生的位置。

func printStack() {
    var buf [4096]byte
    n := runtime.Stack(buf[:], false)
    fmt.Printf("Stack trace:\n%s\n", string(buf[:n]))
}

func main() {
    defer printStack()
    panic("Something went wrong!")
}

⑥ P操作:

runtime包提供了与处理器(P)的相关操作,如获取可同时执行的最大P数目、绑定goroutine到特定的P等。

⑦ 信号处理:

runtime包提供了处理C语言信号的函数,用于和外部C库进行交互时的信号处理。

通过使用runtime包提供的函数和变量,可以更控制程序的运行时行为、优化性能、处理错误和调试问题。但需要注意,对runtime包过度依赖可能会降低代码的可移植性

2、相关函数:

runtime包提供了与程序运行时环境交互的函数和变量,包含了与上述作用相关的函数:

① Goroutine相关:

goexit():终止当前goroutine的执行。
GOMAXPROCS(n int):设置可同时执行的最大CPU数。
NumGoroutine():返回当前存在的goroutine数目。

② 垃圾回收:

GC(): 手动触发垃圾回收。
SetFinalizer(obj interface{}, finalizerpython interface{}):为对象设置一个垃圾回收的终结器(finalizer),当对象被垃圾回收时,终结器会被调用。

③ 栈:

Stack(buf []byte, all bool): 返回当前goroutine的堆栈信息。
StackTrace(p *Profiling)::返回当前程序的完整堆栈跟踪。

④ 内存统计:

ReadMemStats(m *MemStats): 获取当前程序的内存使用统计信息。

⑤ 并发控制:

LockOSThread(): 锁定当前goroutine到当前线程上。
UnlockOSThread(): 解除当前goroutine对当前线程的锁定。

(等)

同样的,由于其对底层进行交互,过多使用相关函数也会降低可移植性,开发过程中需要注意。

3、几个较为重要的函数:

① runtime.Gosched():让出CPU时间片,重新等待安排任务

package main

import (
    "fmt"
    "runtime"
)

func main() {
    go func(s string) {
        for i := 0; i < 2; i++ {
            fmt.Println(s)
        }
    }("world")
    // 主协程
    for i := 0; i < 2; i++ {
        // 切一下,再次分配任务
        runtime.Gosched()
        fmt.Println("hello")
    }
}

② runtime.Goexit():退出当前协程

package main

import (
    "fmt"
    "runtime"
)

func main() {
    go func() {
        defer fmt.Println(www.chinasem.cn"A.defer")
        func() {
            defer fmt.Println("B.defer")
            // 结束协程
            runtime.Goexit()
            defer fmt.Println("C.defer")
            fmt.Println("B")
        }()
        fmt.Println("A")
    }()
    for {
    }
}

③ runtime.GOMAXPROCS:

Go运行时的调度器使用GOMAXPROCS参数来确定需要使用多少个OS线程来同时执行Go代码。默认值是机器上的CPU核心数。例如在一个8核心的机器上,调度器会把Go代码同时调度到8个OS线程上(GOMAXPROCS是m:n调度中的n)。

Go语言中可以通过runtime.GOMAXPROCS()函数设置当前程序并发时占用的CPU逻辑核心数。

Go1.5版本之前,默认使用的是单核心执行。Go1.5版本之后,默认使用全部的CPU逻辑核心数。

可以通过将任务分配到不同的CPU逻辑核心上实现并行的效果

func a() {
    for i := 1; i < 10; i++ {
        fmt.Println("A:", i)
 China编程   }
}

func b() {
    for i := 1; i < 10; i++ {
        fmt.Println("B:", i)
    }
}

func main() {
    runtime.GOMAXPROCS(1)
    go a()
    go b()
    time.Sleep(time.Second)
}

两个任务只有一个逻辑核心,此时是做完一个任务再做另一个任务。 将逻辑核心数设为2,此时两个任务并行执行,代码如下。

func a() {
    for i := 1; i < 10; i++ {
        fmt.Println("A:", i)
    }
}

func b() {
    for i := 1; i < 10; i++ {
        fmt.Println("B:", i)
    }
}

func main() {
    runtime.GOMAXPROCS(2)
    go a()
    go b()
    time.Sleep(time.Second)
}

二、底层设计:

Go语言的高效与简洁,离不开其运行时环境。runtime包作为Go语言运行时系统的核心接口,承载着内存管理、协程调度、垃圾回收、类型信息处理等关键功能。深入理解runtime包的底层设计,可以深入了解Go语言的运行机制。

1、内存管理与垃圾回收的底层协作

① 内存分配策略

runtime包中的内存分配器采用分层设计,分为线程缓存(Thread Cache)、中心缓存(Central Cache)和堆(Heap)三个层级:

• 线程缓存:每个Go线程拥有独立的线程缓存,用于快速分配小对象(通常小于16字节),避免频繁访问全局资源,减少锁竞争;

• 中心缓存:作为线程缓存的补充,负责从堆中获取大块内存,并切割成适合线程缓存的小块,平衡各线程间的内存使用;

• 堆:内存分配的最终来源,由垃圾回收器统一管理,当线程缓存和中心缓存无法满足需求时,直接从堆中分配内存 。

② 垃圾回收协同工作

垃圾回收器(GC)与内存分配器紧密配合,runtime包通过一系列函数控制GC的行为,如runtime.GC()可手动触发垃圾回收。在GC过程中:

• 标记阶段:从根对象(如全局变量、栈上变量)出发,标记所有可达对象;

• 清除阶段:回收未被标记的对象,将其占用的内存归还到空闲列表;

• 整理阶段(可选):在特定情况下,对堆内存进行整理,减少内存碎片 。

2、协程调度的底层实现细节

runtime包是协程调度的核心执行者,基于M:N调度模型实现高效的协程调度:

• Goroutine(G):用户态的轻量级线程,是Go语言并发的基本单元;

MAChine(M):对应操作系统线程,负责执行Goroutine中的代码;

• Processor(P):协程调度的关键组件,维护本地协程队列,绑定到M上以减少上下文切换开销。

调度过程中,runtime包通过以下机制确保协程高效运行:

• 本地队列优先:P优先从本地队列获取Goroutine执行,减少竞争;

• 工作窃取算法:当本地队列为空时,P从其他P的本地队列窃取Goroutine,均衡负载;

• 阻塞处理:当M执行的Goroutine发生阻塞(如I/O操作),M与P分离,P绑定到其他空闲M继续执行其他Goroutine,避免线程浪费 。

3、运行时类型信息与反射支持

runtime包管理着程序中所有类型的元数据,这些信息是反射功能的基础:

• 类型描述:通过结构体记录类型的大小、对齐方式、方法集合等信息,如rtype结构体存储类型的基本属性,itab结构体记录接口类型与具体实现类型的映射关系;

• 反射实现:reflect包依赖runtime包提供的类型信息,在运行时动态获取对象的类型、调用方法、修改属性 。

例如,在进行反射操作时,runtime包负责提供类型比较、方法查找等底层支持,确保反射操作的正确性和高效性。

4、runtime包与开发者实践

虽然runtime包的大部分功能在幕后自动运行,但开发者在某些场景下仍需关注其行为:

• 性能调优:通过runtime.GOMAXPROCS()设置处理器数量,优化协程调度效率;利用runtime/pprof包进行性能分析,定位内存泄漏、CPU瓶颈等问题;

• 特殊场景处理:在需要与操作系统深度交互时,使用runtime包提供的系统调用接口;在编写高性能程序时,通过runtime包的内存分配函数手动管理内存 。

总结 

到此这篇关于Go学习记录之runtime包深入解析的文章就介绍到这了,更多相关Go runtime包内容请搜索编程China编程(www.chinasem.cn)以前的文章或继续浏览下面的China编程相关文章希望大家以后多多支持China编程(www.chinasem.cn)!

这篇关于Go学习记录之runtime包深入解析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1154995

相关文章

go动态限制并发数量的实现示例

《go动态限制并发数量的实现示例》本文主要介绍了Go并发控制方法,通过带缓冲通道和第三方库实现并发数量限制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录带有缓冲大小的通道使用第三方库其他控制并发的方法因为go从语言层面支持并发,所以面试百分百会问到

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont

Go语言编译环境设置教程

《Go语言编译环境设置教程》Go语言支持高并发(goroutine)、自动垃圾回收,编译为跨平台二进制文件,云原生兼容且社区活跃,开发便捷,内置测试与vet工具辅助检测错误,依赖模块化管理,提升开发效... 目录Go语言优势下载 Go  配置编译环境配置 GOPROXYIDE 设置(VS Code)一些基本

Spring Boot 3.x 中 WebClient 示例详解析

《SpringBoot3.x中WebClient示例详解析》SpringBoot3.x中WebClient是响应式HTTP客户端,替代RestTemplate,支持异步非阻塞请求,涵盖GET... 目录Spring Boot 3.x 中 WebClient 全面详解及示例1. WebClient 简介2.

在MySQL中实现冷热数据分离的方法及使用场景底层原理解析

《在MySQL中实现冷热数据分离的方法及使用场景底层原理解析》MySQL冷热数据分离通过分表/分区策略、数据归档和索引优化,将频繁访问的热数据与冷数据分开存储,提升查询效率并降低存储成本,适用于高并发... 目录实现冷热数据分离1. 分表策略2. 使用分区表3. 数据归档与迁移在mysql中实现冷热数据分

C#解析JSON数据全攻略指南

《C#解析JSON数据全攻略指南》这篇文章主要为大家详细介绍了使用C#解析JSON数据全攻略指南,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、为什么jsON是C#开发必修课?二、四步搞定网络JSON数据1. 获取数据 - HttpClient最佳实践2. 动态解析 - 快速

Spring Boot3.0新特性全面解析与应用实战

《SpringBoot3.0新特性全面解析与应用实战》SpringBoot3.0作为Spring生态系统的一个重要里程碑,带来了众多令人兴奋的新特性和改进,本文将深入解析SpringBoot3.0的... 目录核心变化概览Java版本要求提升迁移至Jakarta EE重要新特性详解1. Native Ima

使用Go实现文件复制的完整流程

《使用Go实现文件复制的完整流程》本案例将实现一个实用的文件操作工具:将一个文件的内容完整复制到另一个文件中,这是文件处理中的常见任务,比如配置文件备份、日志迁移、用户上传文件转存等,文中通过代码示例... 目录案例说明涉及China编程知识点示例代码代码解析示例运行练习扩展小结案例说明我们将通过标准库 os

spring中的@MapperScan注解属性解析

《spring中的@MapperScan注解属性解析》@MapperScan是Spring集成MyBatis时自动扫描Mapper接口的注解,简化配置并支持多数据源,通过属性控制扫描路径和过滤条件,利... 目录一、核心功能与作用二、注解属性解析三、底层实现原理四、使用场景与最佳实践五、注意事项与常见问题六

Zabbix在MySQL性能监控方面的运用及最佳实践记录

《Zabbix在MySQL性能监控方面的运用及最佳实践记录》Zabbix通过自定义脚本和内置模板监控MySQL核心指标(连接、查询、资源、复制),支持自动发现多实例及告警通知,结合可视化仪表盘,可有效... 目录一、核心监控指标及配置1. 关键监控指标示例2. 配置方法二、自动发现与多实例管理1. 实践步骤