Go并发编程：利用WaitGroup实现Goroutine的优雅同步

package main

import (
    "fmt"
    "os"
    "time" // 用于演示问题
)

type uniprot struct {
    namesInDir chan string
}

func (u *uniprot) produce(n string) {
    u.namesInDir <- n
}

func (u *uniprot) consume() {
    fmt.Println(<-u.namesInDir)
}

func (u *uniprot) readFilenames(dirname string) {
    u.namesInDir = make(chan string, 15) // 创建一个带缓冲的通道
    dir, err := os.Open(dirname)
    if err != nil {
        // errorCheck(err) // 假设这里有错误处理
        fmt.Printf("Error opening directory: %v\n", err)
        return
    }
    defer dir.Close()

    names, err := dir.Readdirnames(0)
    if err != nil {
        // errorCheck(err) // 假设这里有错误处理
        fmt.Printf("Error reading directory names: %v\n", err)
        return
    }

    for _, n := range names {
        go u.produce(n) // 启动生产者Goroutine
        go u.consume()  // 启动消费者Goroutine
    }
    // 在这里，主Goroutine可能会立即退出，而不等待produce和consume完成
    // time.Sleep(time.Second) // 演示：短暂等待可以观察到输出
}

func main() {
    u := &uniprot{}
    // 创建一个临时目录和文件用于测试
    testDir := "test_dir"
    os.Mkdir(testDir, 0755)
    defer os.RemoveAll(testDir) // 清理
    for i := 0; i < 5; i++ {
        os.WriteFile(fmt.Sprintf("%s/file%d.txt", testDir, i), []byte("content"), 0644)
    }

    u.readFilenames(testDir)
    fmt.Println("Main Goroutine finished.") // 这句话可能在任何输出之前打印
    time.Sleep(time.Millisecond * 100) // 给予一点时间观察，但不是可靠的同步方式
}

package main

import (
    "fmt"
    "os"
    "sync" // 导入sync包
)

type uniprot struct {
    namesInDir chan string
}

// produce函数现在接受一个WaitGroup指针
func (u *uniprot) produce(n string, wg *sync.WaitGroup) {
    defer wg.Done() // Goroutine完成后调用Done()
    u.namesInDir <- n
    fmt.Printf("Produced: %s\n", n) // 增加日志以观察
}

// consume函数现在接受一个WaitGroup指针
func (u *uniprot) consume(wg *sync.WaitGroup) {
    defer wg.Done() // Goroutine完成后调用Done()
    val := <-u.namesInDir
    fmt.Printf("Consumed: %s\n", val)
}

func (u *uniprot) readFilenames(dirname string) {
    u.namesInDir = make(chan string, 15) // 创建一个带缓冲的通道
    dir, err := os.Open(dirname)
    if err != nil {
        // errorCheck(err)
        fmt.Printf("Error opening directory: %v\n", err)
        return
    }
    defer dir.Close()

    names, err := dir.Readdirnames(0)
    if err != nil {
        // errorCheck(err)
        fmt.Printf("Error reading directory names: %v\n", err)
        return
    }

    var wg sync.WaitGroup // 声明一个WaitGroup
    for _, n := range names {
        wg.Add(2) // 每次循环启动两个Goroutine，所以计数器加2
        go u.produce(n, &wg) // 将WaitGroup的地址传递给Goroutine
        go u.consume(&wg)   // 将WaitGroup的地址传递给Goroutine
    }

    wg.Wait() // 阻塞直到所有Goroutine都调用了Done()
    close(u.namesInDir) // 所有生产者和消费者都完成后，关闭通道
}

func main() {
    u := &uniprot{}
    // 创建一个临时目录和文件用于测试
    testDir := "test_dir"
    os.Mkdir(testDir, 0755)
    defer os.RemoveAll(testDir) // 清理
    for i := 0; i < 5; i++ {
        os.WriteFile(fmt.Sprintf("%s/file%d.txt", testDir, i), []byte("content"), 0644)
    }

    u.readFilenames(testDir)
    fmt.Println("Main Goroutine finished, all tasks completed.")
}