您当前的位置:首页 > 电脑百科 > 程序开发 > 语言 > Go语言

如何高效地使用Goroutine,你学会了?

时间:2023-11-28 13:56:19  来源:微信公众号  作者:Go先锋

概述

Go 语言的强大之处在于其内置的并发支持,而 goroutine 是其并发编程的核心。

本文将讨论如何高效使用 goroutine,通过清晰的示例代码和注释,帮助读者更好地理解和应用并发编程。

 

1. 了解 goroutine 的基础

goroutine 的创建

package mAIn


import (
  "fmt"
  "time"
)


func main() {
  // 创建并启动goroutine
  go func() {
    for i := 0; i < 5; i++ {
      fmt.Println("Goroutine:", i)
      time.Sleep(time.Second)
    }
  }()


  // 主goroutine
  for i := 0; i < 3; i++ {
    fmt.Println("Main:", i)
    time.Sleep(time.Second)
  }
}

 

2. goroutine 之间的通信

用通道进行通信

package main


import (
  "fmt"
  "sync"
  "time"
)


func main() {
  var wg sync.WaitGroup
  ch := make(chan int)


  // 启动goroutine发送数据
  wg.Add(1)
  go func() {
    defer wg.Done()
    for i := 0; i < 5; i++ {
      ch <- i
      time.Sleep(time.Second)
    }
    close(ch)
  }()


  // 启动goroutine接收数据
  wg.Add(1)
  
  go func() {
    defer wg.Done()
    for num := range ch {
      fmt.Println("Received:", num)
    }
  }()


  // 等待所有goroutine执行完毕
  wg.Wait()
}

 

3. 避免 goroutine 泄漏

使用带缓冲的通道

package main


import (
  "fmt"
  "sync"
)


func main() {
  var wg sync.WaitGroup


  // 创建带缓冲的通道
  ch := make(chan int, 3)


  // 启动goroutine发送数据
  wg.Add(1)
  go func() {
    defer wg.Done()
    for i := 0; i < 5; i++ {
      ch <- i
    }
    close(ch)
  }()


  // 启动goroutine接收数据
  wg.Add(1)
  go func() {
    defer wg.Done()
    for num := range ch {
      fmt.Println("Received:", num)
    }
  }()


  // 等待所有goroutine执行完毕
  wg.Wait()
}

 

4. 控制 goroutine 的数量

使用有限的 goroutine 池

package main


import (
  "fmt"
  "sync"
  "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() {
  const numJobs = 5
  const numWorkers = 3


  jobs := make(chan int, numJobs)
  results := make(chan int, numJobs)


  // 启动goroutine池
  var wg sync.WaitGroup
  for w := 1; w <= numWorkers; w++ {
    wg.Add(1)
    go func(workerID int) {
      defer wg.Done()
      worker(workerID, jobs, results)
    }(w)
  }


  // 提供工作
  for j := 1; j <= numJobs; j++ {
    jobs <- j
  }
  close(jobs)


  // 收集结果
  go func() {
    wg.Wait()
    close(results)
  }()


  // 输出结果
  for res := range results {
    fmt.Println("Result:", res)
  }
}

5. 使用 sync 包进行同步

sync.WaitGroup 等待 goroutine 完成

package main


import (
  "fmt"
  "sync"
  "time"
)


func main() {
  var wg sync.WaitGroup


  // 启动多个goroutine
  for i := 1; i <= 3; i++ {
    wg.Add(1)
    go func(id int) {
      defer wg.Done()
      time.Sleep(time.Second)
      fmt.Println("Goroutine", id, "completed")
    }(i)
  }


  // 等待所有goroutine执行完毕
  wg.Wait()
  fmt.Println("All goroutines completed")
}

 

6. 性能调优和注意事项

避免共享状态

package main


import (
  "fmt"
  "sync"
  "time"
)


func main() {
  var mu sync.Mutex
  counter := 0


  for i := 0; i < 5; i++ {
    go func() {
      mu.Lock()
      defer mu.Unlock()
      counter++
    }()
  }


  time.Sleep(time.Second)
  fmt.Println("Counter:", counter)
}

 

7. 总结

通过本文的例子和讨论,对如何高效使用 goroutine 有了更深入的理解。

理解 goroutine 的创建、通信、避免泄漏、控制数量、同步等方面的技巧,将有助于读者在实际项目中更好地应用 Go 语言的并发编程特性。

并发不仅是 Go 语言的一项强大功能,更是构建高性能应用的关键。



Tags:Goroutine   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,不构成投资建议。投资者据此操作,风险自担。如有任何标注错误或版权侵犯请与我们联系,我们将及时更正、删除。
▌相关推荐
Go 中 Goroutines 轻量级并发
并发是现代软件开发的一个基本概念,使程序能够同时执行多个任务。在 Go 编程领域,理解 Goroutines 是至关重要的。本文将全面概述 Goroutines,它们的轻量级特性,如何使用 go 关...【详细内容】
2023-12-22  Search: Goroutine  点击:(133)  评论:(0)  加入收藏
如何高效地使用Goroutine,你学会了?
概述Go 语言的强大之处在于其内置的并发支持,而 goroutine 是其并发编程的核心。本文将讨论如何高效使用 goroutine,通过清晰的示例代码和注释,帮助读者更好地理解和应用并发编...【详细内容】
2023-11-28  Search: Goroutine  点击:(172)  评论:(0)  加入收藏
Goroutine 开启和退出到底做了什么?
Illustration created for “A Journey With Go”, made from the original Go Gopher, created by Renee French.ℹ️本文基于 Go 1.14。在 Go 中,协程就是一个包含程序运行...【详细内容】
2021-04-15  Search: Goroutine  点击:(521)  评论:(0)  加入收藏
goroutine的退出与泄露:如何检测和预防
Go中,goroutine是否结束执行(退出)是由其自身决定,其他goroutine只能通过消息传递的方式通知其关闭,而并不能在外部强制结束一个正在执行的goroutine。当然有一种特殊情况会导致正在运行的goroutine会因为其他goroutine的...【详细内容】
2020-07-29  Search: Goroutine  点击:(423)  评论:(0)  加入收藏
资源不断被耗尽,排查起来焦头烂额:如何避免 goroutine 泄露?
Go 中的并发性是以 goroutine(独立活动)和 channel(用于通信)的形式实现的。处理 goroutine 时,程序员需要小心翼翼地避免泄露。如果最终永远堵塞在 I/O 上(例如 channel 通信),或...【详细内容】
2019-09-26  Search: Goroutine  点击:(812)  评论:(0)  加入收藏
▌简易百科推荐
宝藏级Go语言开源项目——教你自己动手开发互联网搜索引擎
DIYSearchEngine 是一个能够高速采集海量互联网数据的开源搜索引擎,采用 Go 语言开发。Github 地址:https://github.com/johnlui/DIYSearchEngine运行方法首先,给自己准备一杯...【详细内容】
2024-03-12  OSC开源社区    Tags:Go语言   点击:(18)  评论:(0)  加入收藏
Go Gin框架实现优雅地重启和停止
在Web应用程序中,有时候我们需要重启或停止服务器,无论是因为更新代码还是进行例行维护。在这种情景下,我们需要保证应用程序的可用性和数据的一致性。这就需要优雅地关闭和重...【详细内容】
2024-01-30  源自开发者  微信公众号  Tags:Go   点击:(67)  评论:(0)  加入收藏
如何让Go程序以后台进程或daemon方式运行
本文探讨了如何通过Go代码实现在后台运行的程序。最近我用Go语言开发了一个WebSocket服务,我希望它能在后台运行,并在异常退出时自动重新启动。我的整体思路是将程序转为后台...【详细内容】
2024-01-26  Go语言圈  微信公众号  Tags:Go程序   点击:(60)  评论:(0)  加入收藏
深入Go底层原理,重写Redis中间件实战
Go语言以其简洁、高效和并发性能而闻名,深入了解其底层原理可以帮助我们更好地利用其优势。在本文中,我们将探讨如何深入Go底层原理,以及如何利用这些知识重新实现一个简单的Re...【详细内容】
2024-01-25  547蓝色星球    Tags:Go   点击:(66)  评论:(0)  加入收藏
Go 内存优化与垃圾收集
Go提供了自动化的内存管理机制,但在某些情况下需要更精细的微调从而避免发生OOM错误。本文将讨论Go的垃圾收集器、应用程序内存优化以及如何防止OOM(Out-Of-Memory)错误。Go...【详细内容】
2024-01-15  DeepNoMind  微信公众号  Tags:Go   点击:(61)  评论:(0)  加入收藏
Go函数指针是如何让你的程序变慢的?
导读Go 语言的常规优化手段无需赘述,相信大家也能找到大量的经典教程。但基于 Go 的函数值问题,业界还没有太多深度讨论的内容分享。本文作者根据自己对 Go 代码的使用与调优...【详细内容】
2024-01-15  腾讯云开发者  微信公众号  Tags:Go函数   点击:(85)  评论:(0)  加入收藏
Go编程中调用外部命令的几种场景
在很多场合, 使用Go语言需要调用外部命令来完成一些特定的任务, 例如: 使用Go语言调用Linux命令来获取执行的结果,又或者调用第三方程序执行来完成额外的任务。在go的标准库...【详细内容】
2024-01-09  suntiger    Tags:Go编程   点击:(100)  评论:(0)  加入收藏
Go 语言不支持并发读写 Map,为什么?
Go语言的map类型不支持并发读写的主要原因是并发读写会导致数据竞态(data race),这意味着多个 goroutine 可能同时访问并修改同一个 map,从而引发不确定的结果。在Go语言的设计...【详细内容】
2024-01-05  Go语言圈  微信公众号  Tags:Go 语言   点击:(77)  评论:(0)  加入收藏
Go微服务入门到容器化实践
Go微服务入门到容器化实践Go 是一门高效、现代化、快速增长的编程语言,非常适合构建 Web 应用程序。而 Docker 是一种轻量级的容器化技术,能够使得您的应用程序在任何地方运行...【详细内容】
2024-01-01  大雷家吃饭    Tags:Go微服务   点击:(61)  评论:(0)  加入收藏
你是否想知道如何应对高并发?Go语言为你提供了答案!
并发编程是当前软件领域中不可忽视的一个关键概念。随着CPU等硬件的不断发展,我们都渴望让我们的程序运行速度更快、更快。而Go语言在语言层面天生支持并发,充分利用现代CPU的...【详细内容】
2023-12-29  灵墨AI探索室  微信公众号  Tags:Go语言   点击:(107)  评论:(0)  加入收藏
站内最新
站内热门
站内头条