golang 함수 파이프라인 통신 모드의 장단점 비교

package main

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

func main() {
    // 创建一个通道来存储要转换的图片路径
    imagePaths := make(chan string)

    // 创建一个管道来存储转换后的图片
    convertedImages := make(chan []byte)

    // 创建一个工作池来处理图片转换
    var wg sync.WaitGroup
    for i := 0; i < 4; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            // 从管道中接收图片路径
            for imagePath := range imagePaths {
                // 转换图片
                output, err := exec.Command("convert", imagePath, "-resize", "50x50", "-").Output()
                if err != nil {
                    fmt.Printf("Error converting image: %v", err)
                    continue
                }
                // 将转换后的图片发送到管道中
                convertedImages <- output
            }
        }()
    }

    // 从目录中读取图片路径
    files, err := ioutil.ReadDir("images")
    if err != nil {
        fmt.Printf("Error reading images: %v", err)
        return
    }
    for _, f := range files {
        if f.IsDir() {
            continue
        }
        //将图片路径发送到管道中
        imagePaths <- f.Name()
    }
    // 关闭管道，表示没有更多图像要转换
    close(imagePaths)

    // 从管道中接收转换后的图像并将其保存到磁盘
    for convertedImage := range convertedImages {
        filename := fmt.Sprintf("converted-%s", time.Now().Format("2006-01-02-15-04-05"))
        err = ioutil.WriteFile(filename, convertedImage, 0644)
        if err != nil {
            fmt.Printf("Error saving image: %v", err)
            continue
        }
    }
    // 等待工作池完成
    wg.Wait()
}