goroutine 或多线程在 golang 中不起作用

Question

我试图在 golang 中实现多线程。我能够实现 go 例程，但它没有按预期工作。下面是我准备的示例程序，

func test(s string, fo *os.File) {
    var s1 [105]int
    count :=0
    for x :=1000; x<1101;x++ {
    s1[count] = x;
        count++
    }

    //fmt.Println(s1[0])
    for i := range s1 {
        runtime.Gosched() 
        sd := s + strconv.Itoa(i)
        var fileMutex sync.Mutex
        fileMutex.Lock()
        fmt.Fprintf(fo,sd)
        defer fileMutex.Unlock()
    }
}

func main() {
    fo,err :=os.Create("D:/Output.txt")
    if err != nil {
        panic(err)
    }
    for i := 0; i < 4; i++ {
        go test("bye",fo) 

    }



}

输出-good0bye0bye0bye0bye0good1bye1bye1bye1bye1good2bye2bye2bye2bye2....等。 上面的程序会创建一个文件，并在文件中写入“Hello”和“bye”。

我的问题是我正在尝试创建 5 个线程并想用不同的线程处理不同的值。如果你会看到上面的例子，它打印了 4 次“bye”。

我希望使用 5 个线程进行如下输出，

good0bye0good1bye1good2bye2....等等....

知道如何实现吗？

Answer 1

首先，您需要阻塞您的 main 函数，直到所有其他 goroutine 返回。程序中的互斥锁不会阻塞任何东西，而且由于它们在每个循环中都会重新初始化，因此它们甚至不会在自己的 goroutine 中阻塞。如果您没有从函数返回，则不能推迟解锁，您需要在循环的每次迭代中显式解锁。您没有使用数组中的任何值（尽管您应该使用切片），因此我们可以完全放弃它。在行为良好的程序中也不需要runtime.GoSched，它在这里什么也不做。

将运行完成的等效程序如下所示：

var wg sync.WaitGroup

var fileMutex sync.Mutex

func test(s string, fo *os.File) {
    defer wg.Done()
    for i := 0; i < 105; i++ {
        fileMutex.Lock()
        fmt.Fprintf(fo, "%s%d", s, i)
        fileMutex.Unlock()
    }
}

func main() {
    fo, err := os.Create("D:/output.txt")
    if err != nil {
        log.Fatal(err)
    }
    for i := 0; i < 4; i++ {
        wg.Add(1)
        go test("bye", fo)

    }
    wg.Wait()
}

最后，没有理由尝试从多个 goroutine 将串行值写入单个文件，这样做效率较低。如果您希望在整个文件中排序值，则无论如何您都需要使用单个 goroutine。