Golang goroutine协程(一) 编写第一个并发处理的程序
发布时间:2020-12-16 18:12:34 所属栏目:大数据 来源:网络整理
导读:package main import ( "fmt" "runtime" "sync" ) var wg sync.WaitGroup //它是一个计数的信号量 func SayHi(s string) { defer wg.Done() //每一个goroutine的函数执行完之后,就调用Done方法对计数器减1 for i := 0; i 50000; i++ { //runtime.Gosched()表
package main
import ( "fmt" "runtime" "sync" ) var wg sync.WaitGroup //它是一个计数的信号量 func SayHi(s string) { defer wg.Done() //每一个goroutine的函数执行完之后,就调用Done方法对计数器减1 for i := 0; i < 50000; i++ { //runtime.Gosched()表示让CPU把时间片让给别人,下次某个时候继续恢复执行该goroutine runtime.Gosched() fmt.Println(i,s) } } func main() { //要根据电脑的实际物理核数调整参数4的大小,如果不是多核的,设置再多的逻辑处理器个数也没用 runtime.GOMAXPROCS(4) //4表示设置的逻辑处理器个数,4 ≤ runtime.NumCPU(),其中NumCPU()是CPU的物理内核个数 wg.Add(2) //先是使用Add方法设置计数器为2 go SayHi("world") go SayHi("hello") //Wait方法如果计数器大于0,就会阻塞主进程结束 //假如主进程结束了,上面的go协程还没来得及输出一个结果,整个程序就运行结束了 wg.Wait() fmt.Println("finished") //main函数里执行的代码都是主进程代码 }
[root@contoso100 ~]# tail -2000 hello.txt|awk '{print NR,$0}'|xargs -n12 ##快速查看hello.txt最后2000行输出结果 [root@contoso100 ~]# awk '{printf"%s %stt%s",NR,$0,NR%5?"":"n"}' hello.txt [root@contoso100 ~]#cat > myprint.format [root@contoso100 ~]# more myprint.format [root@contoso100 ~]# awk -f myprint.format hello.txt
(编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |