这是一个创建于 2891 天前的主题，其中的信息可能已经有所发展或是发生改变。
golang 这里有人用吗
居然没有内置这种功能。。。
想到个办法，在此抛砖引玉
刚试着弄了个，思路是制造一个链式的结构，
链上的每个元素对应一个 goroutine ，这个 goroutine
读取上一个节点发过来的数据扔到输出 channel 上，并转发给下一个。
输出 channel 阻塞就退出自己。（所以发送必须比接收慢）
而且链上有多少个节点，相当于多少容量的 buffer ，
无法确认消息送达到全部 channel
type chaincast struct {
v interface{} //message payload.
out chan interface{} //message output channel
spawn chan<- chaincast //send to this channel to spawn goroutine for chain element.
next chan chaincast //channel for passing message to next
prev chan chaincast //channel for receiving message from prev
}
代码在这，可能有大 bug ：
https://play.golang.org/p/6D9wZ9Qnp8
居然没有内置这种功能。。。
想到个办法，在此抛砖引玉
刚试着弄了个，思路是制造一个链式的结构，
链上的每个元素对应一个 goroutine ，这个 goroutine
读取上一个节点发过来的数据扔到输出 channel 上，并转发给下一个。
输出 channel 阻塞就退出自己。（所以发送必须比接收慢）
而且链上有多少个节点，相当于多少容量的 buffer ，
无法确认消息送达到全部 channel
type chaincast struct {
v interface{} //message payload.
out chan interface{} //message output channel
spawn chan<- chaincast //send to this channel to spawn goroutine for chain element.
next chan chaincast //channel for passing message to next
prev chan chaincast //channel for receiving message from prev
}
代码在这，可能有大 bug ：
https://play.golang.org/p/6D9wZ9Qnp8
 |
1
SuperFashi 2017-01-31 14:55:01 +08:00 via Android
用途？
|
 |
2
Valyrian 2017-01-31 14:58:43 +08:00
以前用 golang 作业写过类似的东西。。
|
 |
3
Siril OP |
 |
4
ovear 2017-01-31 15:09:53 +08:00
这个不是直接封装 chan 就好了么
一个分发 chan ，一个 slice ，多个处理 chan 分发 chan 里面直接循环往 slice 的 chan 塞东西就好了。。有啥问题么？ |
 |
5
jarlyyn 2017-01-31 15:14:02 +08:00 via Android
没看懂用途
|
|
6
jarlyyn 2017-01-31 15:16:20 +08:00 via Android
|
 |
7
buckethead1 2017-01-31 15:30:30 +08:00
就是 pub/sub 么...
|
|
8
Siril OP @jarlyyn
对，就是一个 go routine 负责从外部读取一些东西塞 chan ， 其他一组 go routine 需要取 chan ， 这组 go routine 随时有新增和退出。 如果不用 mutex 。。。 |
 |
9
lecher 2017-01-31 15:53:17 +08:00 via Android
生产者和消费者模型，七牛的公开技术文档经常提到这个设计模式在内部项目的应用场景。
|
 |
10
wweir 2017-01-31 15:59:47 +08:00 via Android
chan 的 close 信号是广播的
|
|
11
Siril OP @ovear 我似乎理解你说的意思，就是元素为 chan 的 slice 。
一开始就是这么弄的， 然后发现 2 个问题： 新开的 goroutine 需要获取一个 chan 用来收消息； 一个收消息的 goroutine 可能随时退出，然后这个 slice 大小只增不减。 |
|
12
ovear 2017-01-31 17:22:53 +08:00
|
|
13
SuperFashi 2017-01-31 18:16:12 +08:00
|
 |
14
nareix 2017-02-01 09:37:59 +08:00
sync.Cond
|
 |
15
codehz 2017-03-20 17:53:37 +08:00
我记得反射就可以了。。。性能应该会比用链式结构的好吧
`reflect.Select`可以接收一个数组 |
Select Language