go - runtime.LockOSThread() 和 runtime.UnlockOSThread 问题

Question

我有这样的代码，

Routine 1 {
runtime.LockOSThread()
print something
send int to routine 2
runtime.UnlockOSThread

}

Routine 2 {
runtime.LockOSThread()
print something
send int to routine 1
runtime.UnlockOSThread

}


main {
go Routine1
go Routine2
}

我使用运行时锁定解锁，因为我不想打印例程 1 将与例程 2 混合。但是，执行完上述操作后代码，它的输出与没有锁定解锁相同(意味着打印输出混合)。任何人都可以帮助我为什么这件事发生以及如何强制这发生了。

注意:我举了一个 print something 的例子，但是有很多打印和发送事件。

Answer 1

如果你想序列化“打印一些东西”，例如每个“打印一些东西”都应该以原子方式执行，然后只是序列化它。

您可以用互斥体包围“打印一些东西”。除非代码因此而死锁，否则它会起作用 - 并且肯定它很容易在一个非平凡的程序中实现。

在 Go 中序列化某些东西的简单方法是使用 channel 。在一个(go)例程中收集所有应该一起打印的东西。完成打印单元的收集后，通过 channel 将其作为“打印作业”单元发送给某个打印“代理”。该代理将简单地接收其“任务”并自动打印每一个。人们可以免费获得这种原子性，作为一项重要的奖励，在只有非相互依赖的“打印单元”生成 goroutine 的简单情况下，代码不再容易死锁。

我的意思是:

func printer(tasks chan string) {
        for s := range tasks {
                fmt.Printf(s)
        }
}

func someAgentX(tasks chan string) {
        var printUnit string
        //...
        tasks <- printUnit
        //...
}

func main() {
        //...
        tasks := make(chan string, size)
        go printer(tasks)
        go someAgent1(tasks)
        //...
        go someAgentN(tasks)
        //...
        <- allDone
        close(tasks)
}