比较 Go 通道的值的方法

小伙伴们对Golang编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《比较 Go 通道的值的方法》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

我有两个通道，首先给我一些字符串，我需要将其过滤为相同的值，然后将结果发送到第二个通道

func main() {
    c := make(chan string, 5)
    o := make(chan string, 5)
    arr := []string{"aa", "ab", "ab", "bb", "bb", "ba", "cc"}
    for _, v := range arr {
        c <- v
        go removeduplicates(c, o)
        time.sleep(1 * time.second)
        fmt.println("output: ", <-o)
    }
}

func removeduplicates(cin, cout chan string) {
   last := ""
   for cur, isopen := <-cin; isopen; {
      if cur != last {
        fmt.printf("val: %s, last: %s\n", cur, last) 
        last = cur
        cout <- cur
        //close(cout)
      }
   }
}

我尝试将以前的值保存到“last”变量，但是当我运行程序时，“last”为空

val: aa, last: 
output:  aa
val: ab, last: 
output:  ab
val: ab, last:

而且我不知道在这种情况下何时以及哪些通道需要关闭。 感谢您的帮助和关注

解决方案

首先修复 removeduplicates()

问题是您的 for statement 中有一个空的 post 语句：

for cur, isopen := <-cin; isopen; {
    // ..
}

因此，您从 cin 通道接收一次，但您再也不会收到更多，您在 post 语句中什么也不做，所以您只是无休止地重复循环体。

一旦循环体执行完毕，就必须再次接收：

for cur, isopen := <-cin; isopen; cur, isopen = <-cin {
    // ..
}

这样，输出将是（在 Go Playground 上尝试）：

val: aa, last: 
output:  aa
val: ab, last: aa
output:  ab
val: ab, last: 
output:  ab
val: bb, last: ab
output:  bb
val: bb, last: 
output:  bb
val: ba, last: ab
output:  ba
val: cc, last: 
output:  cc

但最好是在通道上使用 作为 range：

for cur := range cin {
    if cur != last {
        fmt.printf("val: %s, last: %s\n", cur, last)
        last = cur
        cout <- cur
    }
}

这输出相同。请拨打 Go Playground 试试这个。

现在开始修复 main()

我们看到“无效”输出，输出中的值仍然重复。

这是因为您启动了多个运行 removeduplicates() 的 goroutine。这是不好的，因为在输入通道上发送的值将被多个 goroutine 接收，并且如果重复的值没有被一个 goroutine 接收，它们仍然可以被检测为唯一，因此相同的值将被多次发送到输出.

让单个生产者发送输入通道上的所有值，发送所有值后，关闭通道。

让单个 goroutine 过滤值，使用 for range，一旦循环退出（所有输入值都被消耗），关闭输出通道。

并让单个 goroutine 从输出通道接收值，使用 for range，这样您就可以消除丑陋的 time.sleep：

func main() {
    c := make(chan string, 5)
    o := make(chan string, 5)

    go func() {
        arr := []string{"aa", "ab", "ab", "bb", "bb", "ba", "cc"}
        for _, v := range arr {
            c <- v
        }
        close(c)
    }()

    go removeduplicates(c, o)

    for v := range o {
        fmt.println("output: ", v)
    }
}

func removeduplicates(cin chan string, cout chan string) {
    last := ""
    for cur := range cin {
        if cur != last {
            fmt.printf("val: %s, last: %s\n", cur, last)
            last = cur
            cout <- cur
        }
    }
    close(cout)
}

这将输出（在 Go Playground 上尝试）：

val: aa, last: 
val: ab, last: aa
val: bb, last: ab
val: ba, last: bb
val: cc, last: ba
output:  aa
output:  ab
output:  bb
output:  ba
output:  cc

我已经对代码进行了注释，以便您能够理解。请参考以下代码：

package main

import (
    "fmt"
    "sync"
)

func main() {
    var (
        c  = make(chan string, 1)
        o  = make(chan string, 1)
        wg = sync.WaitGroup{}
    )

    stream := []string{"aa", "ab", "ab", "bb", "bb", "ba", "cc"}

    wg.Add(1)
    // Wait until all the values are received
    defer wg.Wait()
    // Getter receives the filtered out stream
    go getter(o, &wg)

    // Removes duplicates from the stream
    go removeDuplicates(c, o)

    // Send elems to removeDuplicates
    for _, elem := range stream {
        c <- elem
    }
    // Close the channel
    close(c)
}

// getter recieves the filtered out elements
func getter(cOut <-chan string, wg *sync.WaitGroup) {
    defer wg.Done()
    for val := range cOut {
        fmt.Println("Output: ", val)
    }
}

// removeDuplicates removes the adjacent duplicates
func removeDuplicates(cIn chan string, cOut chan string) {
    var last string
    for cur := range cIn {
        if cur != last {
            fmt.Printf("val: %s, last: %s\n", cur, last)
            last = cur
            cOut <- cur
        }
    }
    close(cOut)
}

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~