函数链在 golang 并发编程中的优势包括代码的可读性、并发性、可组合性；局限性有顺序执行、复杂错误处理、可能影响内存使用。例如，通过管道连接一系列函数，可以创建可并发执行的处理链，用于筛选、转换和验证文本文件中的单词。

Golang 函数链在并发编程中的优势和局限性

什么是函数链？

函数链是一种编程技巧，通过将一系列函数以管道的方式串联在一起，形成一个处理数据的处理链。在 Golang 中，可以使用 pipe 函数来创建管道，它允许将一个函数的输出作为另一个函数的输入。

优势：

立即学习“go语言免费学习笔记（深入）”；

• 代码的可读性和可维护性：函数链将复杂的处理逻辑分解成更小的、更易于管理的块，使代码更容易阅读和维护。
• 并发性：每个管道阶段可以并发执行，从而充分利用多核 CPU 的优势。
• 可组合性：函数链可以很容易地组合在一起，创建更复杂的处理管道。

局限性：

• 顺序执行：管道中每个阶段按顺序执行，这可能会导致在某些情况下出现瓶颈。
• 错误处理：处理错误可能很复杂，因为需要考虑整个管道中发生的错误。
• 内存使用：每个管道阶段都可能创建新的内存分配，这可能会影响内存使用。

实战案例：

创建一个管道处理文件内容：

package main

import (
    "bufio"
    "fmt"
    "os"
    "regexp"
    "strings"
    "time"
)

func main() {
    // 从文件读取数据并将其分割成单词
    data, err := readFile("input.txt")
    if err != nil {
        fmt.Println(err)
        return
    }
    tokens := strings.Split(data, " ")

    // 创建一个管道链
    pipe := func(in chan string) <-chan string {
        out := make(chan string)
        go func() {
            defer close(out)
            for v := range in {
                time.Sleep(100 * time.Millisecond) // 模拟延迟
                out <- v
            }
        }()
        return out
    }

    // 添加一个管道阶段来过滤空单词
    filteredOut := pipe(tokens)
    filtered := func(in chan string) <-chan string {
        out := make(chan string)
        go func() {
            defer close(out)
            for v := range in {
                if v != "" {
                    out <- v
                }
            }
        }()
        return out
    }

    // 添加一个管道阶段来转换单词为大写
    upperOut := filtered(filteredOut)
    upper := func(in chan string) <-chan string {
        out := make(chan string)
        go func() {
            defer close(out)
            for v := range in {
                out <- strings.ToUpper(v)
            }
        }()
        return out
    }

    // 添加一个管道阶段来验证单词是否包含特定模式
    validatedOut := upper(upperOut)
    validated := func(in chan string) <-chan string {
        out := make(chan string)
        go func() {
            defer close(out)
            r := regexp.MustCompile("^[A-Z]+$")
            for v := range in {
                if r.MatchString(v) {
                    out <- v
                }
            }
        }()
        return out
    }

    // 打印最终结果
    for v := range validated(validatedOut) {
        fmt.Println(v)
    }
}

func readFile(path string) (string, error) {
    file, err := os.Open(path)
    if err != nil {
        return "", err
    }
    defer file.Close()

    scanner := bufio.NewScanner(file)
    scanner.Split(bufio.ScanLines)
    var data string
    for scanner.Scan() {
        data += scanner.Text() + "n"
    }
    return data, nil
}

在这个示例中，函数链用于处理文本文件的内容，并筛选、转换和验证单词。这种管道方式允许并发执行每个阶段，并生成最终结果。