0

0

Go语言多核并行计算:GOMAXPROCS与并发并非并行

心靈之曲

心靈之曲

发布时间:2025-08-01 21:04:33

|

453人浏览过

|

来源于php中文网

原创

Go语言多核并行计算:GOMAXPROCS与并发并非并行

本文深入探讨了Go语言程序在多核环境下未能充分利用CPU资源的问题。核心在于理解Go的调度器默认行为以及GOMAXPROCS变量的作用。通过设置GOMAXPROCS,我们可以控制Go运行时可使用的操作系统线程数量,从而实现goroutine的并行执行。同时,文章强调了并发与并行的本质区别,并分析了不当设置GOMAXPROCS可能导致的性能下降,提供了优化建议和示例代码。

理解Go协程与并行执行

go语言通过其轻量级的并发原语——goroutine,极大地简化了并发编程。开发者可以使用go关键字轻松启动数千甚至数万个goroutine。然而,一个常见的误解是,启动多个goroutine就意味着程序会自动在多个cpu核心上并行运行。实际上,go的运行时调度器默认情况下可能只会使用一个操作系统线程来执行这些goroutine,即使系统拥有多个可用的cpu核心。这意味着,即使您的机器是多核处理器,go程序也可能仅利用一个核心,无法实现真正的并行计算加速。

GOMAXPROCS:开启并行计算的关键

要让Go程序充分利用多核CPU资源,实现goroutine的并行执行,关键在于设置GOMAXPROCS变量。GOMAXPROCS控制Go运行时可以同时使用的最大操作系统线程数。默认情况下,Go 1.5版本之前,GOMAXPROCS的值默认为1,这意味着即使有多个CPU核心,Go程序也只会使用一个OS线程来调度goroutine。从Go 1.5版本开始,GOMAXPROCS的默认值被设置为CPU核心数,这在大多数情况下能更好地利用多核资源。然而,对于旧版本Go或者某些特定场景,手动设置GOMAXPROCS仍然是必要的。

设置GOMAXPROCS有两种主要方式:

  1. 通过环境变量设置: 在运行Go程序之前,可以通过设置shell环境变量来指定GOMAXPROCS的值。

    export GOMAXPROCS=4 # 设置为4个核心
    go run your_program.go

    或者在执行时直接指定:

    GOMAXPROCS=4 go run your_program.go
  2. 通过runtime包设置: 在程序代码内部,可以使用runtime包的GOMAXPROCS函数来动态设置。这通常是在程序的main函数开头完成。

    import "runtime"
    
    func main() {
        // 设置Go运行时最多使用4个OS线程
        runtime.GOMAXPROCS(4) 
        // 或者设置为CPU核心数
        // runtime.GOMAXPROCS(runtime.NumCPU()) 
    
        // ... 您的并发代码 ...
    }

    推荐使用runtime.NumCPU()来动态获取并设置,以适应不同机器的CPU配置。

    立即学习go语言免费学习笔记(深入)”;

并发与并行:一个重要的区别

理解GOMAXPROCS的作用,需要区分“并发”(Concurrency)和“并行”(Parallelism)这两个概念。

  • 并发:指程序设计能够处理多个同时进行的任务。它关注的是任务的结构,即如何将任务分解成独立的、可以独立执行的部分。Go的goroutine和channel是实现并发的强大工具。即使只有一个CPU核心,程序也可以通过快速切换任务(时间片轮转)来模拟同时执行多个任务,给人一种“同时进行”的错觉。
  • 并行:指多个任务真正地在同一时刻被不同的处理器(或处理器核心)同时执行。并行是并发的一种特殊情况,它需要多核CPU的支持,并且Go运行时需要通过GOMAXPROCS来调度goroutine到不同的OS线程上,进而映射到不同的CPU核心上。

简而言之,Go的go关键字创建的是并发,而要实现并行,则需要GOMAXPROCS来提供足够的OS线程,以便这些并发的任务能够真正在多个CPU核心上同时运行。

易达中小企业CMS管理系统1.8.6
易达中小企业CMS管理系统1.8.6

初次使用易达CMS企业系统以下简称(易达),易达系统运行于微软公司开发的 ASP 程序平台,ASP是目前国内应用最广泛的WEB开发语言,空间基于微软windows IIS,使您的购买空间和维护成本降到最低,并以其众多独创或领先的新特性和功能设计,使得用户深刻体验到易达以原创研发、服务客户为主导开发理念的独到之处和领先优势,易达严格上讲是为懂点网站建设和HTML或DIV+CSS技术的人员而开发的一套

下载

性能考量与最佳实践

虽然增加GOMAXPROCS可以利用多核CPU,但并非总是越大越好。在某些情况下,将其设置得过高反而可能导致程序变慢。这通常发生在以下场景:

  • 频繁的上下文切换开销:当GOMAXPROCS设置得很高,导致Go调度器在多个OS线程之间频繁切换goroutine时,会产生显著的上下文切换开销。
  • 通道通信开销:如果程序中包含大量goroutine,并且它们之间通过通道(channel)进行频繁的数据通信,那么当这些goroutine被调度到不同的OS线程上时,跨线程的数据传输会引入额外的同步和内存访问开销,这可能抵消并行带来的收益。

Go的调度器在不断优化中,但目前它可能无法完全智能地识别所有这类瓶颈。因此,建议根据应用程序的特性和负载,对GOMAXPROCS进行基准测试和调优。通常,将其设置为CPU核心数是一个合理的起点。对于I/O密集型任务,即使GOMAXPROCS设置为1,Go的非阻塞I/O模型也能很好地处理并发。对于计算密集型任务,提高GOMAXPROCS通常能带来性能提升。

示例代码优化

让我们以原问题中的代码为例,演示如何通过设置GOMAXPROCS来尝试实现并行计算。原代码尝试将一个大数的求和任务分解为多个goroutine并行执行,但如果GOMAXPROCS默认值为1,则无法利用多核。

package main

import (
    "fmt"
    "math/big"
    "runtime" // 引入runtime包
    "time"
)

var c chan *big.Int

// sum 函数计算指定范围内的和
func sum(start, stop, step int64) {
    bigStop := big.NewInt(stop)
    bigStep := big.NewInt(step)
    bigSum := big.NewInt(0)
    for i := big.NewInt(start); i.Cmp(bigStop) < 0; i.Add(i, bigStep) {
        bigSum.Add(bigSum, i)
    }
    c <- bigSum
}

func main() {
    // 关键步骤:设置GOMAXPROCS为CPU核心数
    // 这将允许Go运行时使用多个OS线程来调度goroutine
    runtime.GOMAXPROCS(runtime.NumCPU()) 
    fmt.Printf("GOMAXPROCS is set to: %d\n", runtime.GOMAXPROCS(-1)) // 打印当前GOMAXPROCS值

    s := big.NewInt(0)
    n := time.Now().UnixNano() // 使用time.Now().UnixNano()更现代

    step := int64(4) // 启动4个goroutine
    c = make(chan *big.Int, int(step))
    stop := int64(100000000) // 目标求和上限

    // 启动多个goroutine并行计算
    for j := int64(0); j < step; j++ {
        go sum(j, stop, step)
    }

    // 收集所有goroutine的计算结果
    for j := int64(0); j < step; j++ {
        s.Add(s, <-c)
    }

    n = time.Now().UnixNano() - n
    // 打印总和及执行时间(秒)
    fmt.Printf("Total sum: %s, Time taken: %.6f seconds\n", s.String(), float64(n)/1e9)
}

通过在main函数开头添加runtime.GOMAXPROCS(runtime.NumCPU()),我们明确告诉Go运行时可以利用所有可用的CPU核心。对于这种计算密集型的求和任务,这通常会显著提高执行效率,因为各个sum goroutine可以真正在不同的CPU核心上并行执行。

总结

Go语言的并发模型强大而优雅,但要实现真正的并行计算,利用多核CPU的全部潜力,开发者需要理解GOMAXPROCS的作用。通过合理设置GOMAXPROCS,并区分并发与并行,我们可以编写出既高效又充分利用硬件资源的Go程序。在实际应用中,始终建议对不同GOMAXPROCS设置下的程序性能进行测试,以找到最适合特定工作负载的配置。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

525

2023.08.10

Go中Type关键字的用法
Go中Type关键字的用法

Go中Type关键字的用法有定义新的类型别名或者创建新的结构体类型。本专题为大家提供Go相关的文章、下载、课程内容,供大家免费下载体验。

234

2023.09.06

go怎么实现链表
go怎么实现链表

go通过定义一个节点结构体、定义一个链表结构体、定义一些方法来操作链表、实现一个方法来删除链表中的一个节点和实现一个方法来打印链表中的所有节点的方法实现链表。

450

2023.09.25

go语言编程软件有哪些
go语言编程软件有哪些

go语言编程软件有Go编译器、Go开发环境、Go包管理器、Go测试框架、Go文档生成器、Go代码质量工具和Go性能分析工具等。本专题为大家提供go语言相关的文章、下载、课程内容,供大家免费下载体验。

255

2023.10.13

0基础如何学go语言
0基础如何学go语言

0基础学习Go语言需要分阶段进行,从基础知识到实践项目,逐步深入。php中文网给大家带来了go语言相关的教程以及文章,欢迎大家前来学习。

703

2023.10.26

Go语言实现运算符重载有哪些方法
Go语言实现运算符重载有哪些方法

Go语言不支持运算符重载,但可以通过一些方法来模拟运算符重载的效果。使用函数重载来模拟运算符重载,可以为不同的类型定义不同的函数,以实现类似运算符重载的效果,通过函数重载,可以为不同的类型实现不同的操作。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

194

2024.02.23

Go语言中的运算符有哪些
Go语言中的运算符有哪些

Go语言中的运算符有:1、加法运算符;2、减法运算符;3、乘法运算符;4、除法运算符;5、取余运算符;6、比较运算符;7、位运算符;8、按位与运算符;9、按位或运算符;10、按位异或运算符等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

233

2024.02.23

go语言开发工具大全
go语言开发工具大全

本专题整合了go语言开发工具大全,想了解更多相关详细内容,请阅读下面的文章。

285

2025.06.11

2026赚钱平台入口大全
2026赚钱平台入口大全

2026年最新赚钱平台入口汇总,涵盖任务众包、内容创作、电商运营、技能变现等多类正规渠道,助你轻松开启副业增收之路。阅读专题下面的文章了解更多详细内容。

54

2026.01.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Rust 教程
Rust 教程

共28课时 | 5.1万人学习

PostgreSQL 教程
PostgreSQL 教程

共48课时 | 8.2万人学习

Git 教程
Git 教程

共21课时 | 3.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号