假设有一个简单的整数计算器,只支持加法和乘法运算。它将接收一个整数生成器和一个作为加法器或乘数的整数作为其输入参数,并对来自生成器的每个元素应用相应的计算。
我认为下面的粗略序列图恰当地描述了这个逻辑。
但是当我使用 goroutines 和 channels 来实现相同的逻辑时,直接的方法/函数调用关系消失了,因为 goroutines 使用通道来发送和接收数据。
generator := func(integers ...int) <-chan int {
intStream := make(chan int)
go func() {
defer close(intStream)
for _, i := range integers {
intStream <- i
}
}()
return intStream
}
multiply := func(intStream <-chan int, multiplier int) <-chan int {
multipliedStream := make(chan int)
go func() {
defer close(multipliedStream)
for i := range intStream {
multipliedStream <- i*multiplier
}
}()
return multipliedStream
}
add := func(intStream <-chan int, additive int) <-chan int {
addedStream := make(chan int)
go func() {
defer close(addedStream)
for i := range intStream {
addedStream <- i+additive
}
}()
return addedStream
}
intStream := generator(1, 2, 3, 4)
pipeline := multiply(add(intStream, 1), 2)
for v := range pipeline {
fmt.Println(v)
}
诞生的goroutinegenerator作为生产者发送整数;add和中诞生的协程multiply既是生产者又是消费者;他们接收整数,处理它们,并将它们放入新的通道中。最后用两个channel把这3个goroutine连接成一个pipeline,但是我没有想到要呈现的一目了然。
有没有一种面向goroutines的UML图?
慕田峪7331174
相关分类