Go语言中工作池的原理与实现

package main

import (
    "fmt"
    "time"
)

func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        fmt.Println("Worker", id, "processing job", j)
        time.Sleep(time.Second)
        results <- j * 2
    }
}

func main() {
    jobs := make(chan int, 100)
    results := make(chan int, 100)

    // 启动3个worker
    for w := 1; w <= 3; w++ {
        go worker(w, jobs, results)
    }

    // 发送9个任务到队列
    for j := 1; j <= 9; j++ {
        jobs <- j
    }
    close(jobs)

    // 收集所有任务的结果
    for a := 1; a <= 9; a++ {
        <-results
    }
}

package main

import (
    "fmt"
    "net/http"
    "sync"
)

func fetchURL(url string, wg *sync.WaitGroup) {
    defer wg.Done()
    resp, err := http.Get(url)
    if err != nil {
        fmt.Println("Error fetching", url, ":", err)
        return
    }
    defer resp.Body.Close()
    fmt.Println("Fetched", url)
    // 处理响应
}

func main() {
    urls := []string{"http://example.com", "http://google.com", "http://github.com"}
    var wg sync.WaitGroup

    // 创建工作池并启动多个worker
    workerCount := 3
    jobs := make(chan string, len(urls))
    for i := 0; i < workerCount; i++ {
        go func() {
            for url := range jobs {
                fetchURL(url, &wg)
            }
        }()
    }

    // 分发任务
    for _, url := range urls {
        wg.Add(1)
        jobs <- url
    }

    close(jobs)
    wg.Wait()
}

package main

import (
    "fmt"
    "io/ioutil"
    "os"
    "sync"
)

func processFile(filename string, wg *sync.WaitGroup) {
    defer wg.Done()
    // 处理文件逻辑
    fmt.Println("Processing file:", filename)
}

func main() {
    files, err := ioutil.ReadDir("/path/to/files")
    if err != nil {
        fmt.Println("Error reading directory:", err)
        return
    }

    var wg sync.WaitGroup
    workerCount := 4
    jobs := make(chan string, len(files))

    // 启动工作池
    for i := 0; i < workerCount; i++ {
        go func() {
            for file := range jobs {
                processFile(file, &wg)
            }
        }()
    }

    // 分发任务
    for _, file := range files {
        wg.Add(1)
        jobs <- file.Name()
    }

    close(jobs)
    wg.Wait()
}