iis服务器助手广告广告
返回顶部
首页 > 资讯 > 后端开发 > GO >Go并发编程之死锁与活锁的案例分析
  • 457
分享到

Go并发编程之死锁与活锁的案例分析

Go死锁 活锁分析Go 死锁 活锁Go死锁Go活锁 2023-05-18 08:05:22 457人浏览 八月长安
摘要

目录什么是死锁、活锁发生死锁的案例分析发生活锁的案例分析什么是死锁、活锁 什么是死锁:就是在并发程序中,两个或多个线程彼此等待对方完成操作,从而导致它们都被阻塞,并无限期地等待对方完

什么是死锁、活锁

什么是死锁:就是在并发程序中,两个或多个线程彼此等待对方完成操作,从而导致它们都被阻塞,并无限期地等待对方完成。这种情况下,程序会卡死,无法继续执行。

什么是活锁:就是程序一直在运行,但是无法取得进展。例如,在某些情况下,多个线程会争夺同一个资源,然后每个线程都会释放资源,以便其他线程可以使用它。但是,如果没有正确的同步,这些线程可能会同时尝试获取该资源,然后再次释放它。这可能导致线程在无限循环中运行,却无法取得进展。

发生死锁的案例分析

1.编写会发生死锁的代码:

package main

import (
 "fmt"
 "sync"
)

func main() {
 var mu sync.Mutex
 mu.Lock()
 defer mu.Unlock()

 wg := sync.WaitGroup{}
 wg.Add(1)
 Go func() {
  fmt.Println("goroutine started")
  mu.Lock() // 在这里获取了锁
  fmt.Println("goroutine finished")
  mu.Unlock()
  wg.Done()
 }()

 wg.Wait()
}

运行和输出:

[root@workhost temp02]# go run main.go 
goroutine started
fatal error: all goroutines are asleep - deadlock! # 错误很明显了,告诉你死锁啦!

goroutine 1 [seMacquire]:
sync.runtime_Semacquire(0xc000010030?)
        /usr/local/go/src/runtime/sema.go:62 +0x27
...
...

上面的代码,使用 sync.Mutex 实现了一个互斥锁。主 goroutine 获取了锁,并启动了一个新的 goroutine。新 goroutine 也尝试获取锁来执行其任务。但是,由于主 goroutine 没有释放锁,新 goroutine 将一直等待锁,导致死锁。

2.代码改造

在上面的代码中,可以通过将主 goroutine 中的 defer mu.Unlock() 移到 goroutine 函数中的 mu.Unlock() 后面来解决问题。这样,当 goroutine 获取到锁后,它可以在完成任务后释放锁,以便主 goroutine 可以继续执行。

改造后的代码:

package main

import (
 "fmt"
 "sync"
)

func main() {
 var mu sync.Mutex
 mu.Lock()
 wg := sync.WaitGroup{}
 wg.Add(1)
 go func() {
  fmt.Println("goroutine started")
  mu.Lock() // 在这里获取了锁
  fmt.Println("goroutine finished")
  mu.Unlock()
  wg.Done()
 }()
 mu.Unlock() // 释放锁
 wg.Wait()
}

运行和输出:

[root@workhost temp02]# go run main.go 
goroutine started
goroutine finished

3.如何避免死锁

在 Go 语言中,要避免死锁,一定要清楚以下几个规则:

  • 避免嵌套锁:在使用多个锁时,确保它们的嵌套顺序相同。否则,可能会出现循环等待的情况,导致死锁。
  • 避免无限等待:如果在获取锁时指定了超时时间,确保在超时后能够处理错误或执行其他操作。
  • 避免过度竞争:如果多个协程需要访问相同的资源,请确保它们不会互相干扰。可以使用互斥锁或读写锁等机制来解决竞争问题。
  • 使用通道:Go 语言中的通道可以用于协调并发操作。使用通道来传递消息和同步操作,可以避免死锁和竞争问题。
  • 确保资源释放:在使用锁或其他资源时,一定要确保它们在使用后得到释放,否则可能会导致死锁。
  • 使用 select 语句:在使用通道进行并发操作时,可以使用 select 语句来避免死锁。通过 select 语句选择多个通道中的一个进行操作,可以避免在某个通道被阻塞时出现死锁。

发生活锁的案例分析

1.编写会发生活锁的代码:

package main

import (
 "fmt"
 "sync"
)

func main() {
 var wg sync.WaitGroup
 var mu sync.Mutex
 var flag bool

 wg.Add(2)

 // goroutine 1
 go func() {
  // 先获取锁资源
  fmt.Println("goroutine 1 获取 mu")
  mu.Lock()
  defer mu.Unlock()

  // 然后等待 flag 变量的值变为 true
  fmt.Println("goroutine 1 等待标志")
  for !flag {
   // 不断循环等待
  }

  // 最终输出并释放锁资源
  fmt.Println("goroutine 1 从等待中释放")
  wg.Done()
 }()

 // goroutine 2
 go func() {
  // 先获取锁资源
  fmt.Println("goroutine 2 获取 mu")
  mu.Lock()
  defer mu.Unlock()

  // 然后等待 flag 变量的值变为 true
  fmt.Println("GoRoutine2 等待标志")
  for !flag {
   // 不断循环等待
  }

  // 最终输出并释放锁资源
  fmt.Println("GoRoutine 2 从等待中释放")
  wg.Done()
 }()

 // 在主线程中等待 1 秒钟,以便两个 goroutine 开始等待 flag 变量的值
 // 然后将 flag 变量设置为 true
 // 由于两个 goroutine 会同时唤醒并尝试获取锁资源,它们会相互等待
 // 最终导致了活锁问题,它们都无法向前推进
 fmt.Println("主线程休眠 1 秒")
 fmt.Println("两个goroutine都应该等待标志")
 flag = true
 wg.Wait()

 fmt.Println("所有 GoRoutines 已完成")
}

运行和输出:

[root@workhost temp02]# go run main.go 
主线程休眠 1 秒
两个goroutine都应该等待标志
goroutine 2 获取 mu
GoRoutine2 等待标志
GoRoutine 2 从等待中释放
goroutine 1 获取 mu
goroutine 1 等待标志
goroutine 1 从等待中释放
所有 GoRoutines 已完成

上面的代码存在活锁问题。如果两个goroutine同时等待flag变为true并且都已经获取了锁资源,那么它们就会进入一个死循环并相互等待,无法继续向前推进。

2.代码改造

改造后的代码:

package main

import (
 "fmt"
 "runtime"
 "sync"
)

func main() {
 var wg sync.WaitGroup
 var mu sync.Mutex
 var flag bool

 wg.Add(2)

 // goroutine 1
 go func() {
  // 先获取锁资源
  fmt.Println("goroutine 1 获取 mu")
  mu.Lock()
  defer mu.Unlock()

  // 然后等待 flag 变量的值变为 true
  fmt.Println("goroutine 1 等待标志")
  for !flag {
   runtime.Gosched() // 让出时间片
  }

  // 最终输出并释放锁资源
  fmt.Println("goroutine 1 从等待中释放")
  wg.Done()
 }()

 // goroutine 2
 go func() {
  // 先获取锁资源
  fmt.Println("goroutine 2 获取 mu")
  mu.Lock()
  defer mu.Unlock()

  // 然后等待 flag 变量的值变为 true
  fmt.Println("GoRoutine2 等待标志")
  for !flag {
   runtime.Gosched() // 让出时间片
  }

  // 最终输出并释放锁资源
  fmt.Println("GoRoutine 2 从等待中释放")
  wg.Done()
 }()

 // 在主线程中等待 1 秒钟,以便两个 goroutine 开始等待 flag 变量的值
 // 然后将 flag 变量设置为 true
 // 由于两个 goroutine 会同时唤醒并尝试获取锁资源,它们会相互等待
 // 最终导致了活锁问题,它们都无法向前推进
 fmt.Println("主线程休眠 1 秒")
 fmt.Println("两个goroutine都应该等待标志")
 flag = true
 wg.Wait()

 fmt.Println("所有 GoRoutines 已完成")
}

改造后的代码在等待flag变量的循环中加入了让出时间片的函数 runtime.Gosched(),这样两个goroutine在等待期间可以放弃时间片,以便其他goroutine可以执行并获得锁资源。这种方式可以有效地减少竞争程度,从而避免了活锁问题。

3.如何避免发生活锁的可能性

在 Go 语言的并发编程中,避免活锁的关键是正确地实现同步机制。以下是一些避免活锁的方法:

  • 避免忙等待:使用 sync.Cond 或者 channel 等同步机制来实现等待。这样避免了线程一直占用 CPU 资源而无法取得进展的问题。
  • 避免死锁:死锁往往是活锁的前提,因此正确地使用锁和同步机制可以避免死锁,从而避免活锁。
  • 减少锁的粒度:尽可能将锁的粒度缩小到最小范围,避免锁住不必要的代码块。
  • 采用超时机制:使用 sync.Mutex 的 TryLock() 方法或者使用 select 语句实现等待超时机制,这样可以防止线程无限期等待。
  • 合理设计并发模型:合理设计并发模型可以避免竞争和饥饿等问题,进而避免活锁的发生。

以上就是Go并发编程之死锁与活锁的案例分析的详细内容,更多关于Go死锁 活锁的资料请关注编程网其它相关文章!

您可能感兴趣的文档:

--结束END--

本文标题: Go并发编程之死锁与活锁的案例分析

本文链接: https://www.lsjlt.com/news/211903.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑,方便收藏和打印~

下载Word文档
猜你喜欢
  • Go并发编程之死锁与活锁的案例分析
    目录什么是死锁、活锁发生死锁的案例分析发生活锁的案例分析什么是死锁、活锁 什么是死锁:就是在并发程序中,两个或多个线程彼此等待对方完成操作,从而导致它们都被阻塞,并无限期地等待对方完...
    99+
    2023-05-18
    Go死锁 活锁分析 Go 死锁 活锁 Go死锁 Go活锁
  • java并发编程死锁定义及避免死锁案例分析
    这篇文章主要介绍“java并发编程死锁定义及避免死锁案例分析”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“java并发编程死锁定义及避免死锁案例分析”文章能帮助大家解决问题。场景模拟分析场景一:狭路...
    99+
    2023-06-29
  • Java并发问题之乐观锁与悲观锁的示例分析
    这篇文章将为大家详细讲解有关Java并发问题之乐观锁与悲观锁的示例分析,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。首先介绍一些乐观锁与悲观锁:悲观锁:总是假设最坏的情况,每次去拿数据的时候都认为别人会修...
    99+
    2023-05-30
    java
  • Java多线程之死锁的示例分析
    小编给大家分享一下Java多线程之死锁的示例分析,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!什么是死锁死锁是这样一种情形:多个线程同时被阻塞,它们中的一个或者全...
    99+
    2023-05-30
    java
  • python多线程中互斥锁与死锁的示例分析
    小编给大家分享一下python多线程中互斥锁与死锁的示例分析,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!一、多线程间的资源竞争以下列task1(),task2()两个函数为例,分别将对全局变量num加一重复一千万次循环(...
    99+
    2023-06-29
  • Java并发编程中死锁的实现
    这篇文章给大家介绍Java并发编程中死锁的实现,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。一、什么是死锁所谓死锁是指多个线程因竞争资源而造成的一种僵局(互相等待),若无外力作用,这些进程都将无法向前推进二、死锁产生的...
    99+
    2023-06-15
  • Java 内存模型与死锁:深入理解并发编程中的死锁问题
    Java 内存模型(JMM)是一套规范,它定义了 Java 程序中变量是如何在多个线程之间共享的。JMM 规定了线程如何从主内存中读取和写入变量,以及如何将变量的值存储到主内存中。 死锁是并发编程中常见的一种问题,它发生在两个或多个线程...
    99+
    2024-02-04
    Java 内存模型 死锁 并发编程 同步 等待 通知 中断
  • Java并发编程之死锁相关知识整理
    目录一、什么是死锁二、死锁产生的条件三、死锁产生的演示四、死锁的预防五、死锁的避免一、什么是死锁 所谓死锁是指多个线程因竞争资源而造成的一种僵局(互相等待),若无外力作用,这些进程都...
    99+
    2024-04-02
  • Go语言并发编程之互斥锁Mutex和读写锁RWMutex
    目录一、互斥锁Mutex1、Mutex介绍2、Mutex使用实例二、读写锁RWMutex1、RWMutex介绍2、RWMutex使用实例在并发编程中,多个Goroutine访问同一块...
    99+
    2024-04-02
  • INSERT语句引发的死锁实例分析
    这篇文章主要介绍“INSERT语句引发的死锁实例分析”,在日常操作中,相信很多人在INSERT语句引发的死锁实例分析问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”INSERT...
    99+
    2024-04-02
  • MySQL中死锁与日志的示例分析
    这篇文章将为大家详细讲解有关MySQL中死锁与日志的示例分析,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。最近线上 MySQL 接连发生了几起数据异常,都是在凌晨爆发,由...
    99+
    2024-04-02
  • Golang函数并发编程中的死锁处理
    死锁是一种并发编程中的状态,其中多个进程或线程等待对方释放资源,导致程序无法继续进行。go 提供了以下机制来处理死锁:mutex 和通道:用于确保仅一个 goroutine 每次都能访问...
    99+
    2024-04-17
    并发编程 死锁处理 golang
  • Go并发编程的示例分析
    这篇文章给大家分享的是有关Go并发编程的示例分析的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。一、goroutine定义给函数前加上go即可不需要在定义是区分是否是异步函数调度器在合适的点进行切换,这个点是有很多...
    99+
    2023-06-20
  • Go并发编程:资源管理与锁的使用
    go并发编程中资源管理和锁的使用至关重要。go提供了并发安全类型、通道和waitgroup来管理共享资源访问,而互斥锁、读写锁和原子操作则用于控制对资源的访问。实战案例展示了如何使用sy...
    99+
    2024-05-11
    并发编程 并发访问 同步机制 标准库
  • Go并发编程中如何避免死锁和竞态条件
    在 go 并发编程中,为了避免死锁和竞态条件,有以下准则:避免死锁:识别共享资源,指派明确所有者,并使用死锁检测工具。避免竞态条件:使用互斥锁、读写锁或原子操作来确保共享数据的并发访问安...
    99+
    2024-05-13
    并发编程 竞态条件 死锁 golang 并发访问
  • Go语言并发编程中的锁应用
    Go语言是一种开源编程语言,最初由Google开发,旨在提升程序员的效率和系统的性能。Go语言支持并发编程,也就是同时执行多个任务,其中使用锁是一种常见的方式来保证并发安全。在本文中,...
    99+
    2024-04-02
  • Java编程之Synchronized锁住对象的示例分析
    这篇文章主要为大家展示了“Java编程之Synchronized锁住对象的示例分析”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“Java编程之Synchronized锁住对象的示例分析”这篇文章...
    99+
    2023-05-30
    java synchronized
  • java并发编程Lock锁可重入性与公平性分析
    目录一、相似之处:Lock锁 vs Synchronized 代码块二、Lock接口中的方法三、不同点:Lock锁 vs Synchronized 代码块四、锁的可重入性4.1. s...
    99+
    2024-04-02
  • Java并发编程加锁导致的活跃性问题详解方案
    目录死锁(Deadlock)死锁的解决和预防1.超时释放锁2.按顺序加锁3.死锁检测活锁(Livelock)避免活锁饥饿解决饥饿性能问题上下文切换什么是上下文切换?减少上下文切换的方...
    99+
    2024-04-02
  • Go中同时使用并发和并行编程的案例分析
    go 同时支持并发 (通过 goroutine) 和并行 (通过协程) 以提升效率。goroutine 允许同时执行独立任务,而通道则实现 goroutine 之间的通信。该示例演示了如...
    99+
    2024-05-12
    并发 并行 质数
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作