使用goroutines无限迭代文件

package main

import (
    "bufio"
    "fmt"
    "os"
    "sync"
)

func processLine(line string) {
    // 这里可以添加具体的处理逻辑
    fmt.Println(line)
}

func processFile(filePath string, wg *sync.WaitGroup) {
    defer wg.Done()

    file, err := os.Open(filePath)
    if err != nil {
        fmt.Println("Error opening file:", err)
        return
    }
    defer file.Close()

    scanner := bufio.NewScanner(file)
    for scanner.Scan() {
        line := scanner.Text()
        go processLine(line)
    }

    if err := scanner.Err(); err != nil {
        fmt.Println("Error reading file:", err)
    }
}

func main() {
    filePath := "path/to/your/file.txt"
    var wg sync.WaitGroup

    wg.Add(1)
    go processFile(filePath, &wg)

    // 保持主 Goroutine 运行，以便无限迭代
    for {
    }
}

var maxGoroutines = 100
sem := make(chan struct{}, maxGoroutines)

func processLine(line string) {
    sem <- struct{}{}
    defer func() { <-sem }()

    // 这里可以添加具体的处理逻辑
    fmt.Println(line)
}