并发执行但序列化输出

Question

我需要使用 3 个名为 g1、g2、g3 的 goroutine。并以循环方式在上述 3 个 goroutine 中分配 1-10 的数字。他们会根据提供的数字做一些假设性的工作。程序应按以下方式打印输出。

g1-1
g2-2
g3-3
g1-4
g2-5
g3-6
...

任务必须同时执行，但输出必须按顺序执行。

我已经实现了下面的代码来分配数字和打印，但是输出打印顺序不能像上面提到的那样得到保证。

我需要一些帮助来修复以下代码或关于另一种方法的建议以获得上述期望的输出。

方法一：

package main

import (
    "fmt"
    "sync"
)

func main() {

    chang1 := make(chan int)
    chang2 := make(chan int)
    chang3 := make(chan int)

    var wg sync.WaitGroup
    wg.Add(3)

    go func() {
        for num := range chang1 {
            fmt.Println("g1", num)
        }
        wg.Done()
    }()

    go func() {
        for num := range chang2 {
            fmt.Println("g2", num)
        }
        wg.Done()

    }()

    go func() {
        for num := range chang3 {
            fmt.Println("g3", num)
        }
        wg.Done()

    }()

    channels := []chan int{chang1, chang2, chang3}

    for i := 1; i <= 10; i++ {

        currentCh := (i - 1) % 3
        channels[currentCh] <- i

    }

    close(chang1)
    close(chang2)
    close(chang3)
    wg.Wait()

}

输出（顺序不正确）

g1-1
g1- 4
g2-2
g3- 3
g1- 7
g2- 5
g2- 8
g3- 6
g3- 9
g1- 10
...

Answer 1

如果你不想使用 slice 那么我认为这样的方法会起作用：- (playground)

package main

import (
    "fmt"
)

func main() {

    chang1 := make(chan string)
    chang2 := make(chan string)
    chang3 := make(chan string)

    channels := []chan string{chang1, chang2, chang3}

    for i := 1; i < 10; i += 3 {

        go g1(i, channels[i%3])
        go g2(i+1, channels[(i+1)%3])
        go g3(i+2, channels[(i+2)%3])

        fmt.Print(<-channels[i%3])
        fmt.Print(<-channels[(i+1)%3])
        fmt.Print(<-channels[(i+2)%3])
    }

}

func g1(i int, chanel chan string) {

    chanel <- fmt.Sprintln("g1", i)

}

func g2(i int, chanel chan string) {

    chanel <- fmt.Sprintln("g2", i)

}

func g3(i int, chanel chan string) {

    chanel <- fmt.Sprintln("g3", i)

}

output 
g1 1
g2 2
g3 3
g1 4
g2 5
g3 6
g1 7
g2 8
g3 9

但请记住，在此解决方案中，您必须运行 3 个 goroutine，然后等待它们全部给出结果，然后返回

如果这对您来说不合适，您需要使用缓冲通道。

并发执行但序列化输出

Concurrent execution but serialized output

go

goroutine