群晖wordpress配置,东莞市seo网络推广价格,柳州团购网站建设,网站广告费怎么做分录一、协程基本使用
1、启动一个协程
主线程中每个100毫秒打印一次#xff0c;总共打印2次另外开启一个协程#xff0c;打印10次情况一#xff1a;打印是交替#xff0c;证明是并行的情况二#xff1a;开启的协程打印2次#xff0c;就退出了#xff08;因为主线程退出了…一、协程基本使用
1、启动一个协程
主线程中每个100毫秒打印一次总共打印2次另外开启一个协程打印10次情况一打印是交替证明是并行的情况二开启的协程打印2次就退出了因为主线程退出了
package mainimport (fmttime
)func test() {for i :o;i10;i {fmt.PrintIn(test() 你好golang)time.Sleep(time.Millisecond * 100)}
}func main() {go test() //表示开启一个协程for i:0;i2;i {fmt.PrintIn(main() 你好golang)time.Sleep(time.Millisecond * 100)}
}
/*
main() 你好golang
test() 你好golang
main() 你好golang
test() 你好golang
test() 你好golang
*/ 2、WaitGroup等待协程执行完毕
主线程退出后所有的协程无论有没有执行完毕都会退出所以我们在主进程中可以通过WaitGroup等待协程执行完毕 sync.WaitGroup内部维护者一个计数器计数器的值可以增加和减少例如当我们启动了N个并发任务时就将计数器值增加N每个任务完成时通过调用Done()方法将计数器减1通过调用Wait来等待并发任务执行完当计数器值为0时表示所有并发任务已经完成 var wg sync.waitGroup //第一步定义一个计数器 wg.Add(1) //第二步开启一个协程计数器1 wg.Done() //第三步协程执行完毕计数器-1 wg.Wait() //第四步计数器为0时退出 package mainimport (fmtsynctime
)var wg sync.WaitGroup //第一步定义一个计数器func test1() {for i :0;i10;i {fmt.PrintIn(test1() 你好golang,i)time.Sleep(time.Millisecond * 100)}wg.Done() //协程计数器-1 //第三步协程执行玩不计数器-1
}func test2() {for i :0;i2;i {fmt.PrintIn(test2() 你好golang,i)time.Sleep(time.Millisecond * 100)}wg.Done() //协程计数器-1
}func main() {wg.Add(1) //协程计数器1 第二不开启一个协程计数器1go test1() //表示开启一个协程wg.Add(1) //协程计数器1go test2() //表示开启一个协程wg.Wait() //等待协程执行完毕... 第四步计数器为0时退出fmt.PrintIn(主线程退出...)}/*
test2() 你好golang- 0
test1() 你好golang- 0
.....
test1() 你好golang- 8
test1() 你好golang- 9
主线程退出...
*/二、多协程案例
1、开启多个协程
在Go语言中实现并发就是这样简单我们还可以启动多个goroutine这里使用了sync.WaitGroup来实现等待goroutine执行完毕多次执行上面的代码会发现每次打印的数字的顺序都不一致这是因为10个goroutine是并发执行的而goroutine的调度是随机的
package mainimport (fmtsync
)var wg sync.WaitGroupfunc hello(i int){defer wg.Done() //goroutine结束就登记-1fmt.PrintIn(Hello Goroutine!,i)
}func main() {for i :0;i10;i {wg.Add(1) //启动一个goroutine就登记1go hello(i)}wg.Wait() //等待所有登记的goroutine都结束
}
2、多协程统计素数
需求:要统计1-120000的数字中哪些是素数goroutine for循环实现协程 统计 1-30000协程 统计 30001-60000 协程 统计 60001-90000 协程 统计 90001-120000 start:(n-1)*300001 end:n*30000
package main
import (fmtsynctime
)
var wg sync.WaitGroupfunc test(n int) {for num : (n-1)*30000 1; num n*30000; num {if num 1 {var flag truefor i : 2; i num; i {if num%i 0 {flag falsebreak}}if flag {fmt.Println(num, 是素数)}}}wg.Done()
}func main() {start : time.Now().Unix()for i : 1; i 4; i {wg.Add(1)go test(i)}wg.Wait()fmt.Println(执行完毕)end : time.Now().Unix()fmt.Println(end - start) //1毫秒
}
