网站搭建本地环境,网站建设和软件开发,摄影网站cms,外包网站开发公司Go语言作为现代编程语言#xff0c;其并发编程的优势是有目共睹的。在实际编程中#xff0c;我们常常需要保证多个goroutine之间的同步#xff0c;这就需要使用到Go语言的sync标准库。sync库提供了基本的同步原语#xff0c;例如互斥锁#xff08;Mutex#xff09;和等待…Go语言作为现代编程语言其并发编程的优势是有目共睹的。在实际编程中我们常常需要保证多个goroutine之间的同步这就需要使用到Go语言的sync标准库。sync库提供了基本的同步原语例如互斥锁Mutex和等待组WaitGroup这些都是协调和控制并发执行的重要工具。
基础应用
1. 使用Mutex实现互斥
在很多情况下我们需要保证在任意时刻只有一个goroutine能够访问某个数据。这时我们就可以使用Mutex互斥锁来实现这个需求。Mutex有两个方法Lock和Unlock。在Lock和Unlock之间的代码块同一时刻只有一个goroutine可以执行其他尝试执行这部分代码的goroutine会被阻塞直到锁被解开。以下面的例子为例我们试图在多个goroutine中对一个全局变量完成加法操作
package mainimport (fmtsync
)var (sum intmu sync.Mutex
)func worker() {for i : 0; i 10; i {mu.Lock()sum sum 1mu.Unlock()}
}func main() {var wg sync.WaitGroupfor i : 0; i 10000; i {wg.Add(1)go func() {defer wg.Done()worker()}()}wg.Wait()fmt.Println(sum)
}2. 使用WaitGroup等待并发操作结束
在另外一种常见的应用场景中我们需要开启一组goroutine去处理任务而主goroutine需要等待这些任务完成后才能结束。这可以通过sync.WaitGroup来实现。WaitGroup有三个方法Add增加计数Done减少计数Wait等待计数归零。
package mainimport (fmtsynctime
)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.WaitGroupfor i : 1; i 5; i {wg.Add(1)go worker(i, wg)}wg.Wait()
}以上的代码中我们创建了5个worker goroutinemain goroutine 会等待所有的worker都完成工作后才会退出。
进阶应用
以下是一些稍微复杂一些的sync库的使用例子。
全局单例
使用sync.Once来保证某个操作只执行一次。这在初始化全局变量或者单例模式中非常有用。 package mainimport (fmtsync)var once sync.Oncefunc setup() {fmt.Println(Init function)}func worker(wg *sync.WaitGroup, n int) {once.Do(setup)fmt.Println(Worker, n)wg.Done()}func main() {var wg sync.WaitGroupfor i : 0; i 10; i {wg.Add(1)go worker(wg, i)}wg.Wait()}在以上代码中我们保证了setup函数只被执行了一次即使有10个goroutine都尝试去执行setup函数。
条件变量
使用sync.Cond来实现条件变量这可以使得一个或者多个goroutine等待或者通知事件。 package mainimport (fmtsynctime)// Button 定义一个按钮结构体type Button struct {Clicked *sync.Cond}// 模拟一个用户界面func simulate(button *Button) {time.Sleep(time.Second)// 用户点击buttonbutton.Clicked.Broadcast()}func main() {// 初始化Buttonbutton : Button{Clicked: sync.NewCond(sync.Mutex{})}// 显示信息的goroutinefor i : 0; i 10; i {go func(i int) {// 等待button被点击button.Clicked.L.Lock()defer button.Clicked.L.Unlock()button.Clicked.Wait()// button被点击显示一条信息fmt.Println(button clicked,, i)}(i)}// 模拟用户点击buttongo simulate(button)time.Sleep(2 * time.Second)}处理并发是使用Go语言开发中非常重要的一部分理解和掌握sync标准库中的同步原语对于你写出高效可靠的并发程序是非常重要的。
希望这篇文章能够帮助你更好的理解如何在Go语言中进行并发编程我会非常高兴收到你的反馈
