分享
GO语言学习笔记(三)
YaphetS_xiaoyang · · 2766 次点击 · · 开始浏览这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。
- 在一个函数调用前加上关键字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)
有疑问加站长微信联系(非本文作者)
入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889
关注微信2766 次点击
上一篇:Go语言学习笔记说明
下一篇:发点牢骚,Go语言真的没啥好的
添加一条新回复
(您需要 后才能回复 没有账号 ?)
- 请尽量让自己的回复能够对别人有帮助
- 支持 Markdown 格式, **粗体**、~~删除线~~、
`单行代码` - 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
- 图片支持拖拽、截图粘贴等方式上传
收入到我管理的专栏 新建专栏
- 在一个函数调用前加上关键字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)