当前位置: 首页 > 面试题库 >

没有互斥量的情况下同时进行读写时会发生什么

马煌
2023-03-14
问题内容

在Go中,使用sync.Mutexchan阻止并发访问共享对象。但是,在某些情况下,我只是对变量或对象字段的最新值感兴趣。或者我喜欢写一个值,不在乎另一个go例程以后会覆盖它还是之前已经覆盖它。

更新: TLDR;只是不要这样做。这不安全。阅读答案,评论和链接的文档!

这里有两个变量goodbad一个示例程序,其中似乎都使用当前Go运行时产生的“正确”的输出:

package main

import (
    "flag"
    "fmt"
    "math/rand"
    "time"
)

var bogus = flag.Bool("bogus", false, "use bogus code")

func pause() {
    time.Sleep(time.Duration(rand.Uint32()%100) * time.Millisecond)
}

func bad() {
    stop := time.After(100 * time.Millisecond)
    var name string

    // start some producers doing concurrent writes (DANGER!)
    for i := 0; i < 10; i++ {
        go func(i int) {
            pause()
            name = fmt.Sprintf("name = %d", i)
        }(i)
    }

    // start consumer that shows the current value every 10ms
    go func() {
        tick := time.Tick(10 * time.Millisecond)
        for {
            select {
            case <-stop:
                return
            case <-tick:
                fmt.Println("read:", name)
            }
        }
    }()

    <-stop
}

func good() {
    stop := time.After(100 * time.Millisecond)
    names := make(chan string, 10)

    // start some producers concurrently writing to a channel (GOOD!)
    for i := 0; i < 10; i++ {
        go func(i int) {
            pause()
            names <- fmt.Sprintf("name = %d", i)
        }(i)
    }

    // start consumer that shows the current value every 10ms
    go func() {
        tick := time.Tick(10 * time.Millisecond)
        var name string
        for {
            select {
            case name = <-names:
            case <-stop:
                return
            case <-tick:
                fmt.Println("read:", name)
            }
        }
    }()

    <-stop
}

func main() {
    flag.Parse()
    if *bogus {
        bad()
    } else {
        good()
    }
}

预期的输出如下:

...
read: name = 3
read: name = 3
read: name = 5
read: name = 4
...

的任意组合read:read: name=[0-9]这个程序正确的输出。接收任何其他字符串作为输出将是错误的。

与该程序一起运行go run --race bogus.go时是安全的。

但是,go run --race bogus.go -bogus警告并发读取和写入。

对于map类型和附加到切片时,我始终需要互斥或类似的保护方法,以避免出现段错误或意外行为。但是,将文字(原子值)读写到变量或字段值 似乎 是安全的。

问题: 我可以安全地读取和安全地并发写入哪些Go数据类型,而无需使用mutext,不产生段错误以及不从内存中读取垃圾?

解释 为什么有些东西是 安全的或不安全的围棋 在你的答案。

更新
:我重写了该示例以更好地反映原始代码,其中我遇到了并发写入问题。重要的观点已经在评论中。我将接受一个答案,该答案以足够详细的方式总结了这些学习内容(尤其是在Go运行时中)。


问题答案:

但是,在某些情况下,我只是对变量或对象字段的最新值感兴趣。

这是一个基本问题:“最新”一词是什么意思?

从数学上讲,假设我们有一个值 X i_的序列,其中 _0 <= i <N。那么很明显, X Ĵ_是“晚于” _X 我,如果 _J

时我_。这是“最新”的一个很好的简单定义,可能就是您想要的。

但是,当一台机器上的两个单独的CPU(包括Go程序中的两个goroutine)同时工作 时间本身就失去了意义 。我们不能说i j。因此,没有对“ 最新 ”一词的正确定义。

为了解决此类问题,现代的CPU硬件以及Go作为一种编程语言为我们提供了某些 同步原语 。如果CPU A和CPU
B执行内存隔离指令或同步指令,或使用任何其他存在的硬件规定,则CPU(和/或某些外部硬件)将插入“时间”概念所需的任何内容,以重新获得其含义。也就是说,如果CPU使用屏障指令,我们可以说在屏障
之前 执行内存加载或存储是“之前”,而在屏障 之后 执行的内存加载或存储是“之后”。

(在某些现代硬件中,实际实现由加载和存储缓冲区组成,这些缓冲区可以重新排列加载和存储进入内存的顺序。barrier指令要么同步缓冲区,要么在缓冲区中放置实际的屏障,以便加载和存储缓冲区。商店无法跨越屏障移动这种特殊的具体实施给出了一个简单的方法来思考这个问题,但不完整:你应该考虑的时间,根本
不存在 硬件提供的同步之外,即 所有 的负荷,除了这些障碍,某些位置同时发生,而不是按顺序出现。)

无论如何,Go的sync软件包为您提供了一种针对这些障碍的简单高级访问方法。在互斥锁Lock调用之前执行的编译代码确实会 锁定函数返回
之前 完成,并且在调用之后执行的代码实际上直到锁定函数返回 之后 才开始。

Go的频道提供了相同的之前/之后时间保证。

Go的sync/atomic软件包提供了更低级别的保证。通常,应避免这样做,而应使用更高级别的频道或sync.Mutex样式保证。(编辑以添加注释:您
可以
在此处使用sync/atomicPointer操作,但不能string直接使用类型,因为Go字符串实际上是作为包含两个单独值的标头实现的:指针和长度。您可以在另一层通过更新指向该string对象的指针进行间接调用,但是在您考虑这样做之前,您应该对语言的首选方法进行基准测试,并验证它们是否存在问题,因为在该sync/atomic级别上工作的代码很难编写和难以调试。)



 类似资料:
  • Go语言包中的 sync 包提供了两种锁类型:sync.Mutex 和 sync.RWMutex。 Mutex 是最简单的一种锁类型,同时也比较暴力,当一个 goroutine 获得了 Mutex 后,其他 goroutine 就只能乖乖等到这个 goroutine 释放该 Mutex。 RWMutex 相对友好些,是经典的单写多读模型。在读锁占用的情况下,会阻止写,但不阻止读,也就是多个 gor

  • 这个问题是关于布尔值而不是布尔值的(但我很想知道两者是否相同)。假设您有一个函数正在对数据执行多次检查,并且在每种情况下它都有特定的响应。您希望函数显示所有无效输入的大小写(以及它们无效的原因),因此您希望检查所有输入(而不仅仅是一个并停止和返回)。使用单个布尔值(如Boolean x=isValidEmail(String email))然后处理它是否无效并在未来的检查中重用x以使您不分配额外的

  • 我想了解更多关于std::thread的信息,特别是如果我有一个线程向量,并且其中一个线程完成了执行,将会发生什么。 想象一下这个例子: 创建一个线程向量,所有线程都执行以下函数: “char*flag”指向一个标志,表示函数停止执行。 例如,向量包含10个线程,它们都在执行。然后将线程号3的标志设置为零。(向量中的第4个线程,因为向量从零开始。) 好的做法是然后加入线程。 向量现在将包含多少st

  • 当您以“正常”方式停止或重新启动tomcat时,正在处理的http请求会发生什么情况?它们将被处理直到响应完成还是http线程被中断?有没有办法配置优雅的停车?

  • 问题内容: 操作系统是否正确处理? 还是我必须打电话给flock()? 问题答案: 虽然OS不会崩溃,并且文件系统不会被破坏,呼叫被 不 保证的广告是原子的,除非有问题的文件描述符是一个管道,数据的写入量字节或更少。标准的相关部分: 尝试写入管道或FIFO具有几个主要特征: * 原子/非原子:如果一个操作中写入的总量未与任何其他进程的数据交错,则写入是原子的。当有多个作者将数据发送到单个读者时,此

  • 相关问题,但不是我想知道的,因为我对PHPlib/函数的具体行为很好奇: 当连接在事务中间关闭时会发生什么? 当连接关闭时,未提交的事务会发生什么? 假设我有这样的代码(不管它是好的还是坏的实践): 包含提交和回滚的将被跳过,而连接将在事务启动后但在调用提交或回滚之前关闭。 该事务是否也会立即被销毁/结束/不管什么专有名词,或者它会保留下来并可能阻止来自其他服务的其他查询?