使用两个go协程顺序打印一个字符串

ゝ一纸荒年。 2023-10-10 19:18 9阅读 0赞

#### 阅读目录 ####

package main
    
    import (
    	"fmt"
    	"sync"
    	"time"
    )
    
    func main() {
        
    	// 用于协程同步的结构体类型。它提供了等待一组协程完成的功能。
    	var wg sync.WaitGroup
    	wg.Add(2) // 增加等待组的计数器为2
    
    	str := "hello,world"            // 定义字符串
    	str1 := []byte(str)             // 将字符串转换为字节切片
    	sc := make(chan byte, len(str)) // 创建缓冲通道，容量为字符串长度
    	count := make(chan int)         // 创建通道
    
    	// 将字节切片中的元素发送到缓冲通道
    	for _, v := range str1 {
        
    		sc <- v
    	}
    	close(sc)
    
    	// 启动协程 2
    	go func() {
        
    		defer wg.Done()
    		for {
        
    			ball, ok := <-count // 从通道接收数据
    			if ok {
        
    				pri, ok1 := <-sc // 从缓冲通道接收数据
    				if ok1 {
        
    					fmt.Printf("go 2 : %c\n", pri) // 打印接收到的字符
    				} else {
        
    					close(count) // 关闭通道
    					return
    				}
    				count <- ball // 将接收到的数据发送到通道
    			} else {
        
    				return
    			}
    		}
    	}()
    
    	// 启动协程 1
    	go func() {
        
    		defer wg.Done()
    		for {
        
    			time.Sleep(8 * time.Millisecond) // 休眠一段时间
    			ball, ok := <-count              // 从通道接收数据
    			if ok {
        
    				pri, ok1 := <-sc // 从缓冲通道接收数据
    				if ok1 {
        
    					fmt.Printf("go 1 : %c\n", pri) // 打印接收到的字符
    				} else {
        
    					close(count) // 关闭通道
    					return
    				}
    			} else {
        
    				return
    			}
    			count <- ball // 将接收到的数据发送到通道
    		}
    	}()
    
    	count <- 23 // 向通道发送数据
    	wg.Wait()   // 等待协程完成
    }

PS C:\Users\25795\Desktop\Go> go run .\test.go
    go 2 : h
    go 1 : e
    go 2 : l
    go 1 : l
    go 2 : o
    go 1 : ,
    go 2 : w
    go 1 : o
    go 2 : r
    go 1 : l
    go 2 : d
    PS C:\Users\25795\Desktop\Go>