go sync包中的互斥锁Mutex和等待组WaitGroup使用详解

 更新时间:2023年08月02日 11:55:57   作者:移动安全星球  
这篇文章主要为大家介绍了go sync包中的互斥锁Mutex和等待组WaitGroup使用详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

Go 语言的sync包

Go 语言的 sync 包提供了一些基本的同步原语,如互斥锁(Mutex)和等待组(WaitGroup)。这些原语可以帮助你在多个 Go Routine 之间同步状态。

Mutex

互斥锁是一种同步工具,用于保证多个 Go Routine 在访问共享资源时的互斥性。

创建 Mutex:

var m sync.Mutex

使用 Mutex:

m.Lock()
// 临界区,只有获得锁的 Go Routine 才能访问
m.Unlock()

例如,假设我们有一个计数器## sync 包的使用

Go 语言的 sync 包提供了一些基本的同步原语,如互斥锁(Mutex)和等待组(WaitGroup)。这些原语可以帮助你在多个 Go Routine 之间同步状态。

Mutex

互斥锁是一种同步工具,用于保证多个 Go Routine 在访问共享资源时的互斥性。

创建 Mutex:

var m sync.Mutex

使用 Mutex:

m.Lock()
// 临界区,只有获得锁的 Go Routine 才能访问
m.Unlock()

例如,假设我们有一个计数器,我们希望它能在多个 Go Routine 之间安全地使用:

package main
import (
    "fmt"
    "sync"
    "time"
)
type SafeCounter struct {
    v   map[string]int
    mux sync.Mutex
}
func (c *SafeCounter) Inc(key string) {
    c.mux.Lock()
    c.v[key]++
    c.mux.Unlock()
}
func (c *SafeCounter) Value(key string) int {
    c.mux.Lock()
    defer c.mux.Unlock()
    return c.v[key]
}
func main() {
    c := SafeCounter{v: make(map[string]int)}
    for i := 0; i < 1000; i++ {
        go c.Inc("somekey")
    }
    time.Sleep(time.Second)
    fmt.Println(c.Value("somekey"))
}

在这个例子中,SafeCounter 的每个方法在操作 v 之前都会锁定 Mutex 来确保安全访问。

WaitGroup

WaitGroup 是用于等待一组 Go Routines 完成的结构。

使用 WaitGroup:

var wg sync.WaitGroup

每次一个 Go Routine 启动时,我们调用 wg.Add(1)。每次一个 Go Routine 完成时,我们调用 wg.Done()。我们可以使用 wg.Wait() 来阻塞,直到所有的 Go Routines 完成。

例如,假设我们启动了多个 Go Routine 来完成一些工作,我们希望等待它们全部完成:

package main
import (
    "fmt"
    "sync"
    "time"
)
func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Printf("Worker %d starting\n", id)
    time.Sleep(time.Second)
    fmt.Printf("Worker %d done\n", id)
}
func main() {
    var wg sync.WaitGroup
    for i := 1; i <= 5; i++ {
        wg.Add(1)
        go worker(i, &wg)
    }
    wg.Wait()
}

在这个例子中,我们使用 WaitGroup 来等待 5 个 worker Go Routines 完成。

总结

Go 语言的 sync 包提供了互斥锁和等待组等同步原语,它们可以帮助我们在多个 Go Routine 之间同步状态。虽然 Go 语言的并发模型主要是基于 Channels 的,但在某些情况下,使用 sync 包提供的同步原语可能会更加方便或有效。

以上就是go sync包中的互斥锁Mutex和等待组WaitGroup使用详解的详细内容,更多关于go sync包互斥锁等待组的资料请关注脚本之家其它相关文章!

相关文章

  • Golang sync.Once实现单例模式的方法详解

    Golang sync.Once实现单例模式的方法详解

    Go 语言的 sync 包提供了一系列同步原语,其中 sync.Once 就是其中之一。本文将深入探讨 sync.Once 的实现原理和使用方法,帮助大家更好地理解和应用 sync.Once,需要的可以参考一下
    2023-05-05
  • Golang操作MySql数据库的完整步骤记录

    Golang操作MySql数据库的完整步骤记录

    这篇文章主要给大家介绍了关于Golang操作MySql数据库的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-11-11
  • Golang中类型转换利器cast库的用法详解

    Golang中类型转换利器cast库的用法详解

    cast库是一个简洁而强大的第三方库,它的主要功能是实现类型之间的安全转换,而在Golang开发中,类型转换是一个常见且不可避免的过程,下面我们就来看看cast库在Golang中的具体应用吧
    2024-11-11
  • 用Go获取短信验证码的示例代码

    用Go获取短信验证码的示例代码

    要用Go获取短信验证码,通常需要连接到一个短信服务提供商的API,并通过该API发送请求来获取验证码,由于不同的短信服务提供商可能具有不同的API和授权方式,我将以一个简单的示例介绍如何使用Go语言来获取短信验证码,需要的朋友可以参考下
    2023-07-07
  • Go语言声明一个多行字符串的变量

    Go语言声明一个多行字符串的变量

    这篇文章主要介绍了Go语言声明一个多行字符串的变量的方法和示例,非常简单实用,有需要的小伙伴可以参考下。
    2015-04-04
  • Go语言调用Shell与可执行文件的实现

    Go语言调用Shell与可执行文件的实现

    这篇文章主要介绍了Go语言调用Shell与可执行文件的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-10-10
  • Golang WaitGroup 底层原理及源码解析

    Golang WaitGroup 底层原理及源码解析

    WaitGroup 是 Golang 中最常见的并发控制技术之一,它的作用我们可以简单类比为其他语言中多线程并发控制中的 join(),这篇文章主要介绍了Golang WaitGroup 底层原理及源码详解,需要的朋友可以参考下
    2023-04-04
  • Go语言正则表达式示例

    Go语言正则表达式示例

    这篇文章主要介绍了Go语言正则表达式,结合实例形式分析了Go语言正则表达式实现字符串的匹配、查找等相关操作技巧,需要的朋友可以参考下
    2017-01-01
  • Go runtime 调度器之系统调用引起的抢占

    Go runtime 调度器之系统调用引起的抢占

    本文解析了在Go语言中,当goroutine执行的系统调用时间过长时,系统如何通过监控和抢占机制来处理,以维持运行效率和资源分配的平衡,通过具体的示例和流程图,详细展示了系统调用过程中的抢占操作,感兴趣的朋友跟随小编一起看看吧
    2024-09-09
  • Golang中panic与recover的区别

    Golang中panic与recover的区别

    这篇文章主要介绍了Golang中panic与recover的区别,文章基于Golang的基础内容展开panic与recover的区别介绍,需要的小伙伴可以参考一下
    2022-06-06

最新评论