验证我是否能够访问频道

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《验证我是否能够访问频道》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

package main

import (
    "fmt"
    "strconv"
    "time"
)

func generator() chan int {
    ch := make(chan int)
    go func() {
        i := 0
        for {
            i++
            ch <- i
            time.sleep(time.duration(10) * time.millisecond)
        }
    }()
    return ch
}

func printer(delay int, square bool, ch chan int) {
    for n := range ch {
        if (square) {
            fmt.printf("["+strconv.itoa(n) + "],")
        } else {
            fmt.printf("("+strconv.itoa(n) + "),")
        }
        time.sleep(time.duration(delay) * time.millisecond)
    }
}

func sendtoboth(ch chan int) (ch1 chan int, ch2 chan int) {
    ch1 = make(chan int)
    ch2 = make(chan int)
    go func() {
        for {
            //n := <- ch
            select {
                case v := <- ch: //this is the problem point
                    ch1  <- v    //
                case v := <- ch: //
                    ch2 <- v     //
            }
        }
    }()
    return ch1, ch2
}

func main() {
    ch1, ch2 := sendtoboth(generator())
    go printer(100, true, ch1) //[]
    go printer(200, false, ch2) //()
    var name string
    fmt.scan(&name)
}

我想实现 sendtoboth 函数，该函数从通道 ch 获取生成的数字 1,2,3,... 并将其发送到 ch1 和 ch2。但每个都有不同的延迟，我不想等待另一个解锁，所以我尝试使用 select，但无法弄清楚如何询问 if ch1 或 ch2 目前在 case 子句中可用。有什么帮助吗？ 输出应该是这样的

(1),[1],[2],(2),[3],[4],(3),[5],[6],(4),[7],[8],...

解决方案

所以我会说我的第一反应是“让他们步调一致，这样容易多了。”

func sendtoboth(ch chan int) (ch1, ch2 chan int) {
    ch1 = make(chan int)
    ch2 = make(chan int)
    go func() {
        defer close(ch1)
        defer close(ch2)
        for n := range ch {
            ch1 <- n
            ch2 <- n
        }
    }()
    return ch1, ch2
}

很简单，我喜欢！但假设您希望 ch1 和 ch2 以各自的速率被消耗。如果你想让它们彼此分开，你必须使用临时存储来处理这个问题。 简单的解决办法就是给通道一些缓冲空间：

ch1 = make(chan int, 10)
ch2 = make(chan int, 10)

现在，ch1 可以运行得更快，但它只能比 ch2 领先 10 个项目。反之亦然。

如果你想要无限大小的缓冲区，你必须自己保留它。我们可以利用 nil 通道完全可以用作 select 分支这一事实：

func sendToBoth(ch chan int) (ch1, ch2 chan int) {
    ch1 = make(chan int)
    ch2 = make(chan int)
    go func() {
        defer close(ch1)
        defer close(ch2)
        var arr []int
        var pos1, pos2 int
        ich := ch
        for inch != nil && (pos1 < len(arr) || pos2 < len(arr)) {
            var och1, och2 chan int
            var v1, v2 int
            if pos1 < len(arr) {
                och1 = ch1
                v1 = arr[pos1]
            }
            if pos2 < len(arr) {
                och2 = ch2
                v2 = arr[pos2]
            }
            select {
            case n, ok := <- ich:
                if !ok {
                    ich = nil // done
                } else {
                    arr = append(arr, n)
                }
            case och1 <- v1:
                pos1++
            case och2 <- v2:
                pos2++
            }
        }
    }()
    return ch1, ch2
}

有点复杂——我不完全确定这是正确的。另请注意，不会释放流中旧项目的存储空间。

到这里，我们也就讲完了《验证我是否能够访问频道》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！