函数式编程使用管道和 goroutine 处理输入和输出。处理输入时，使用管道和 goroutine 对流数据并行处理。处理输出时，使用管道将数据从一个函数传递到另一个函数。实战案例中，使用管道将处理函数和输出函数连接起来，实现输入处理和输出格式化。这种方法具有可扩展性、并发性和测试性优势。

Go 函数式编程中处理输入和输出

函数式编程注重使用不可变数据结构和纯函数来编写逻辑。这种方法在处理输入和输出时具有独特的好处。

处理输入

要处理输入，我们可以使用管道和 goroutine 来对流数据进行并行处理。例如，我们可以使用以下代码将从标准输入读取的文本行流式传输到管道中：

package main

import (
    "bufio"
    "fmt"
    "log"
    "os"
)

func main() {
    lines := make(chan string)

    go func() {
        s := bufio.NewScanner(os.Stdin)
        for s.Scan() {
            lines <- s.Text()
        }
        close(lines)
    }()

    for line := range lines {
        fmt.Println(line)
    }
}

处理输出

对于输出，我们可以使用管道来将数据从一个函数传递到另一个函数。例如，我们可以使用以下代码将一些字符串流式传输到标准输出：

package main

import (
    "fmt"
    "log"
)

func main() {
    lines := []string{"line1", "line2", "line3"}

    ch := make(chan string)

    go func() {
        for _, line := range lines {
            ch <- line
        }
        close(ch)
    }()

    for line := range ch {
        fmt.Println(line)
    }
}

实战案例

考虑以下实战案例：我们有一个列表，其中包含一些数据。我们希望处理该列表中的数据并以另一种格式输出。

使用函数式编程，我们可以将此任务分解为两个函数：

• 处理函数：负责对列表中的每个元素进行所需的处理。
• 输出函数：负责以所需的格式输出处理后的数据。

我们可以使用管道将处理函数和输出函数连接起来，如下所示：

package main

import (
    "fmt"
    "log"
)

func main() {
    lines := []string{"line1", "line2", "line3"}

    process := func(in <-chan string) <-chan string {
        out := make(chan string)

        go func() {
            for line := range in {
                out <- line + "-processed"
            }
            close(out)
        }()

        return out
    }

    output := func(in <-chan string) {
        for line := range in {
            fmt.Println(line)
        }
    }

    processed := process(lines)
    output(processed)
}

这种方法提供了以下好处：

• 可扩展性：我们可以轻松地添加或修改处理或输出逻辑，而无需修改其他部分。
• 并发性：通过使用管道，我们可以并行处理数据。
• 测试性：处理和输出函数是独立的，因此易于单独测试。