goroutine，并行，协程，通道，控制，并发顺序

2024-01-05 07:21:11

前言
goroutine 是 Go 语言中实现并发编程的，可以将一个函数声明为一个 goroutine，并在它开始执行时为它创建一个新的线程。channel 是 Go 语言中实现并发编程的另一种关键字，它可以创建一个通道，用于在 goroutine 之间传递数据。

使用 goroutine 和 channel 控制并发的顺序

有以下几种方法可以使用 goroutine 和 channel 来控制并发的顺序：

使用 channel 来控制 goroutine 的启动顺序。

package main

import (
	"fmt"
	"sync"
)

func main() {
	var wg sync.WaitGroup

	// 创建一个 channel 来控制 goroutine 的启动顺序。
	startChannel := make(chan bool)

	// 创建一个 goroutine。
	wg.Add(1)
	go func() {
		defer wg.Done()

		// 等待 startChannel 接收信号。
		<-startChannel

		fmt.Println("Goroutine 1 started.")
	}()

	// 创建另一个 goroutine。
	wg.Add(1)
	go func() {
		defer wg.Done()

		// 等待 startChannel 接收信号。
		<-startChannel

		fmt.Println("Goroutine 2 started.")
	}()

	// 发送信号给 startChannel，启动 goroutine。
	startChannel <- true

	// 等待所有 goroutine 完成。
	wg.Wait()
}

使用 channel 来控制 goroutine 的执行顺序。

package main

import (
	"fmt"
	"sync"
)

func main() {
	var wg sync.WaitGroup

	// 创建一个 channel 来控制 goroutine 的执行顺序。
	orderChannel := make(chan int)

	// 创建一个 goroutine。
	wg.Add(1)
	go func() {
		defer wg.Done()

		// 等待 orderChannel 接收信号。
		<-orderChannel

		fmt.Println("Goroutine 1 executed.")
	}()

	// 创建另一个 goroutine。
	wg.Add(1)
	go func() {
		defer wg.Done()

		// 等待 orderChannel 接收信号。
		<-orderChannel

		fmt.Println("Goroutine 2 executed.")
	}()

	// 发送信号给 orderChannel，启动 goroutine。
	orderChannel <- 1
	orderChannel <- 2

	// 等待所有 goroutine 完成。
	wg.Wait()
}

使用 channel 来控制 goroutine 的退出顺序。

package main

import (
	"fmt"
	"sync"
)

func main() {
	var wg sync.WaitGroup

	// 创建一个 channel 来控制 goroutine 的退出顺序。
	exitChannel := make(chan bool)

	// 创建一个 goroutine。
	wg.Add(1)
	go func() {
		defer wg.Done()

		// 等待 exitChannel 接收信号。
		<-exitChannel

		fmt.Println("Goroutine 1 exited.")
	}()

	// 创建另一个 goroutine。
	wg.Add(1)
	go func() {
		defer wg.Done()

		// 等待 exitChannel 接收信号。
		<-exitChannel

		fmt.Println("Goroutine 2 exited.")
	}()

	// 发送信号给 exitChannel，退出 goroutine。
	exitChannel <- true
	exitChannel <- true

	// 等待所有 goroutine 完成。
	wg.Wait()
}