- 在一个函数调用前加上关键字go，这次调用就会在一个新的goroutine（轻量级线程，协程）中执行，当被调用函数返回时，这个goroutine也就结束了，如果这个函数有返回值，那么这个返回值将被丢弃
- go语言中的锁机制和channel
package main import ( "fmt" "sync" "runtime" ) var counter int = 0 func Count(lock *sync.Mutex) { lock.Lock() counter ++ fmt.Println(counter) lock.Unlock() } func main() { lock := &sync.Mutex{} for i := 0; i < 10; i ++ { go Count(lock) } for { lock.Lock() c := counter lock.Unlock() runtime.Gosched() if c >= 10 { break } } }
package main import ( "fmt" ) func Count(ch chan int) { fmt.Println("Counting") ch <- 1 } func main() { chs := make([]chan int, 10) for i := 0; i < 10;i ++ { chs[i] = make(chan int) go Count(chs[i]) } for _, ch := range(chs) { <-ch } } - channel声明方法
var ch chan int 声明一个map，元素是bool型的channel: var m map[string] chan bool
- 向channel中写入数据
ch <- val
- 从channel中读出数据
val := <- ch
- select用法
select { case <-chan1: // 如果chan1成功读到数据，则进行该case处理语句 case chan2 <- 1: // 如果成功向chan2写入数据，则进行该case处理语句 default: // 如果上面都没有成功，则进入default处理流程 } - 关闭通道，判断通道是否关闭
关闭通道，直接使用Go内置的close(ch) 判断通道是否关闭，使用多重返回值方式 x, ok := <- ch
- runtime.Gosched()方法用于出让时间片,runtime.NumCPU()用于获得cpu核心数，runtime.GOMAXPROCS(16)设置routine使用多少个CPU核心
- 全局唯一性操作sync.Once.Do(func)
有疑问加站长微信联系（非本文作者）
