Golang goroutine协程(一) 编写第一个并发处理的程序
2017-06-18 02:54
197 查看
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函数里执行的代码都是主进程代码
}
![](https://img-blog.csdn.net/20170618011211728)
![](https://img-blog.csdn.net/20170618025141033)
![](https://img-blog.csdn.net/20170618025525053)
[root@contoso100 ~]# tail -2000 hello.txt|awk '{print NR,$0}'|xargs -n12 ##快速查看hello.txt最后2000行输出结果
[root@contoso100 ~]# awk '{printf"%s %s\t\t%s",NR,$0,NR%5?"":"\n"}' hello.txt
![](https://img-blog.csdn.net/20170618120943969)
[root@contoso100 ~]#cat > myprint.format
{ if(NR%4 == 0)
printf("%s%s",NR" ",$0 "\n")
else
printf("%s%s",NR" ",$0 "\t""\t")
}
[root@contoso100 ~]# more myprint.format
{ if(NR%4 == 0)
printf("%s%s",NR" ",$0 "\n")
else
printf("%s%s",NR" ",$0 "\t""\t")
}
[root@contoso100 ~]# awk -f myprint.format hello.txt
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 %s\t\t%s",NR,$0,NR%5?"":"\n"}' hello.txt
[root@contoso100 ~]#cat > myprint.format
{ if(NR%4 == 0)
printf("%s%s",NR" ",$0 "\n")
else
printf("%s%s",NR" ",$0 "\t""\t")
}
[root@contoso100 ~]# more myprint.format
{ if(NR%4 == 0)
printf("%s%s",NR" ",$0 "\n")
else
printf("%s%s",NR" ",$0 "\t""\t")
}
[root@contoso100 ~]# awk -f myprint.format hello.txt
相关文章推荐
- 编写程序,接受从键盘3输入的10个十进制数字,输入中遇见回车符则停止输入,各个数经过BCD码处理,以16进制显示
- 编写你的第一个Windows程序
- MOSS 2007 应用随笔(18)-- 使用SPEventHandler事件处理程序(二)编写事件程序
- 编写你的第一个Hibernate程序 (在Hibernate中使用oracle的sequence产生主键 )
- 手工编写第一个J2ME程序
- 自己编写的第一个程序!
- 以一个初学者的眼光看自己编写的第一个j2EE程序
- 第一课,编写第一个OpenGL程序
- 第一个java程序编写视频
- VS2005配置和编写第一个ICE程序
- 编写第一个JavaScript程序
- 在你用JSP-servlet编写程序时候可以用以下简单的乱码处理解决!!
- 用VB编写的第一个WINDOWS程序----计算器
- delphi编写你的第一个com程序
- 汇编语言程序设计:编写程序完成将第二个字符串插到第一个字符串的指定位置上
- 用Glassfish和NetBeans编写第一个AJAX程序
- 编写第一个Silverlight程序
- 编写你的第一个Hibernate程序
- 编写第一个J2ME程序
- 第一章 编写第一个单片机程序