golang学习笔记之并发优化(一)
发布时间:2020-12-16 18:15:13 所属栏目:大数据 来源:网络整理
导读:golang在并发上面还是很优雅的,有事细节大家可能不太了解。 多处通知 一次当wait阻塞等待done时,如果完成后,所有之前阻塞的wait都将收到通知,这样就可以通知多个协程。 package main import ( "fmt" "sync" "time" ) func main () { var wg sync .W aitG
golang在并发上面还是很优雅的,有事细节大家可能不太了解。 多处通知一次当wait阻塞等待done时,如果完成后,所有之前阻塞的wait都将收到通知,这样就可以通知多个协程。 package main
import ( "fmt" "sync" "time" ) func main() { var wg sync.WaitGroup wg.Add(1) go func() { fmt.Println("wait1 enter") wg.Wait() fmt.Println("wait1 exit") }() go func() { fmt.Println("wait2 enter") wg.Wait() fmt.Println("wait2 exit") }() go func() { time.Sleep(time.Second) fmt.Println("done") wg.Done() }() wg.Wait() time.Sleep(time.Second) fmt.Println("main exit") }
结果如下: package main
import (
"fmt"
"sync"
"time"
)
func main() {
var wg sync.WaitGroup
ready := make(chan int )
wg.Add(3)
for i :=0;i<3;i++{
go func(i int) {
defer wg.Done()
fmt.Println("reading",i)
<-ready
fmt.Println("go",i)
}(i)
}
time.Sleep(time.Second)
fmt.Println("ready go")
close(ready)
wg.Wait()
}
通过关闭管道或得通知。这样就可以实现组播或者广播 特殊管道已关闭通道读写package main
import (
"fmt"
)
func main() {
ready := make(chan int,1)
ready<-2
close(ready)
fmt.Println(<-ready)
fmt.Println(<-ready)
}
像已经关闭的通道写数据或者重复关闭通道都会panic,读是没有问题的,如果有数据会读取到数据,没有的话会读取到零值。 nil通道读写针对nil管道,无论是读写都会阻塞 package main
import (
"fmt"
"time"
)
func main() {
var a chan int
go func() {
fmt.Println("start")
//a <-1
<-a
fmt.Println("end")
}()
fmt.Println(a)
time.Sleep(time.Second)
fmt.Println("main exit")
}
结果 package main
import (
"sync"
)
func main() {
var wg sync.WaitGroup
wg.Add(3)
a,b := make(chan int ),make(chan int )
go func() {
defer wg.Done()
for {
select {
case x,ok :=<-a:
if !ok{
a =nil
break
}
println("a:",x)
case y,ok :=<-b:
if !ok{
b=nil
break
}
println("b:",y)
}
if a==nil && b==nil{
return
}
}
}()
go func() {
defer wg.Done()
defer close(a)
for i:=0;i<3;i++{
a<-i
}
}()
go func() {
defer wg.Done()
defer close(b)
for i:=0;i<3;i++{
b<-i*10
}
}()
wg.Wait()
}
结果为: b: 0 a: 0 a: 1 b: 10 a: 2 b: 20 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |