go等待一组协程结束的操作方式

IT行业相对于一般传统行业，发展更新速度更快，一旦停止了学习，很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习，精进自己的技术，尤其是初学者。今天golang学习网给大家整理了《go等待一组协程结束的操作方式》，聊聊协程、go等待、结束，我们一起来看看吧！

go提供了sync包和channel来解决协程同步和通讯。

方式1:

sync.WaitGroup是等待一组协程结束，sync.WaitGroup只有3个方法，Add()添加一个计数，Done()减去一个计数，Wait()阻塞直到所有任务完成。

package main
import (
	"fmt"
	"sync"
	"time"
)
var wg sync.WaitGroup //定义一个同步等待的组
func task(i int){
	fmt.Println("task...",i)
	//耗时操作任务，网络请求，读取文件
	time.Sleep(time.Second)
	wg.Done() //减去一个计数
}
func main(){
	for i:= 0;i

<p>运行结果：</p>
<blockquote>
<p>task... 9</p>
<p>task... 4</p>
<p>task... 6</p>
<p>task... 0</p>
<p>task... 7</p>
<p>task... 5</p>
<p>task... 1</p>
<p>task... 2</p>
<p>task... 8</p>
<p>task... 3</p>
<p>over</p>
</blockquote>
<h2>方式2:</h2>
<p>利用缓冲信道channel协程之间通讯，其阻塞等待功能实现等待一组协程结束，不能保证其goroutine按照顺序执行</p>

<pre class="brush:plain;">
package main
import (
 "fmt"
)
var ch = make(chan int,10)
func task(i int){
 fmt.Println("task...",i)
 ch 

<p>运行结果：</p>
<blockquote>
<p>task... 9</p>
<p>task... 0</p>
<p>task... 1</p>
<p>task... 2</p>
<p>task... 6</p>
<p>task... 7</p>
<p>task... 3</p>
<p>task... 4</p>
<p>task... 8</p>
<p>task... 5</p>
<p>over</p>
</blockquote>
<h2>方式3:</h2>
<p>利用无缓冲的信道channel协程之间通讯，其阻塞等待功能实现等待一组协程结束，保证了其goroutine按照顺序执行</p>

<pre class="brush:plain;">
package main
import (
 "fmt"
 "time"
)
var ch = make(chan int)
func task(i int){
 fmt.Println("task...",i)
 time.Sleep(time.Second)
  

<p>运行结果：</p>
<blockquote>
<p>task... 0</p>
<p>task... 1</p>
<p>task... 2</p>
<p>task... 3</p>
<p>task... 4</p>
<p>task... 5</p>
<p>task... 6</p>
<p>task... 7</p>
<p>task... 8</p>
<p>task... 9</p>
<p>over</p>
</blockquote>
<p><strong>补充：Go中使用Channel等待所有协程结束</strong></p>
<p>让main方法等待所有协程执行完毕再退出。可能一般思路是设置一个共有变量，然后通过修改这个变量的状态。这是通过共享变量来通信的方式，而go要做的是，通过通信来共享内存。</p>
<h2>1. 按顺序执行</h2>
<p>每次通信进行成对通信，当main向协程发送一个写channel时，同时也等待协程返回一个读channel。</p>
<p>这两个channel一定是成对的，所以构造一个结构体</p>

<pre class="brush:plain;">
type worker struct {
    in chan int
    done chan bool
}
 
func chanDemo1(){
    var workers [10]worker 
    for i := 0; i 

<p>这个执行结果完全是按照0-9，先小写再大写的顺序</p>
<p>如果这样顺序执行，还要协程干啥</p>
<h2>2. 批量处理</h2>

<pre class="brush:plain;">
type worker struct {
    in chan int
    done chan bool
}
 
func chanDemo1(){
    var workers [10]worker
    for i := 0; i 

<p>这样的话，先打印小写，再打印大写，但是大小写时顺序不固定</p>
<h2>3. 完全随机</h2>

<pre class="brush:plain;">
func chanDemo1(){
    var workers [10]worker
    for i := 0; i 

<p>这种方式就是完全随机了</p>
<p>使用channel进行树的遍历</p>

<pre class="brush:plain;">
func (node *Node) TraverseFunc(f func(*Node)){
    if node == nil{
        return
    }
    node.Left.TraverseFunc(f)
    f(node)
    node.Right.TraverseFunc(f)
}
 
func (node *Node) TraverseWithChannel() chan *Node{
    out := make(chan *Node)
    go func() {
        node.TraverseFunc(func(node *Node) {
            out  maxNode{
            maxNode = node.Value
        }
    }
    fmt.Println("max node value:", maxNode)
 

以上为个人经验，希望能给大家一个参考，也希望大家多多支持golang学习网。如有错误或未考虑完全的地方，望不吝赐教。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。