我正在学习Go,并且遇到了以下代码片段:
package main
import "fmt"
func sum(a []int, c chan int) {
sum := 0
for _, v := range a {
sum += v
}
c <- sum // send sum to c
}
func main() {
a := []int{7, 2, 8, -9, 4, 0}
c := make(chan int, 2)
go sum(a[0:3], c)
go sum(a[3:6], c)
x := <-c
y := <-c
// x, y := <-c, <-c // receive from c
fmt.Println(x, y)
}
Output:
-5 17
Program exited.
有人可以告诉我为什么“ sum”函数的第二个调用在第一个调用之前通过通道吗?在我看来,输出应为:
17 -5
我还使用无缓冲通道对此进行了测试,它也给出了相同顺序的输出。我想念什么?
您正在代码中调用go例程,但无法确定例程何时结束并将该值传递到缓冲通道。
由于该代码是异步的,因此只要例程完成,它将把数据写入通道,并在另一侧读取。在上面的示例中,您仅调用两个go例程,因此行为是确定的,并且在大多数情况下都会以某种方式生成相同的输出,但是当您增加go例程时,输出将不会相同,并且顺序会有所不同,除非您执行以下操作它同步。
例:
package main
import "fmt"
func sum(a []int, c chan int) {
sum := 0
for _, v := range a {
sum += v
}
c <- sum // send sum to c
}
func main() {
a := []int{7, 2, 8, -9, 4, 2, 4, 2, 8, 2, 7, 2, 99, -32, 2, 12, 32, 44, 11, 63}
c := make(chan int)
for i := 0; i < len(a); i = i + 5 {
go sum(a[i:i+5], c)
}
output := make([]int, 5)
for i := 0; i < 4; i++ {
output[i] = <-c
}
close(c)
fmt.Println(output)
}
此代码在不同样本运行中的输出为
[12 18 0 78 162] [162 78 12 0 18] [12 18 78 162 0]
这是因为goroutines将输出异步写入缓冲的通道。
希望这可以帮助。
问题内容: 刚尝试去最近。我想知道如果您有一条select语句等待在几个通道上进行通信,并且如果消息同时在两个或多个通道上出现,将会发生什么情况。如果所有消息都同时发出,那么select将如何确定接受哪个通道? 谢谢! 问题答案: 从规格: 如果可能发生多种情况,则将做出统一的伪随机选择,以决定执行哪个单一通信。 因此,选择是不确定的。
问题内容: 我正在使用goroutines /频道。这是我的代码。为什么超时情况没有得到执行? 问题答案: 您的超时不会发生,因为您的goroutine 之一会每1.5秒(或大约1.5秒)重复发送一次值在您的频道上,并且只有在2秒钟内没有接收到任何值时才会发生超时。 一旦从接收到一个值,在下一次迭代中将再次执行一个 新的 调用,该调用将返回一个 新的 通道,在该通道上将仅在另外2秒钟后发送一个值。
问题内容: 我试图理解这段代码,不确定为什么第二遍在第一遍之前执行。如果有人真的可以帮助我,那就太好了! 输出: 问题答案: 您没有任何内容可以显式同步两个goroutine的顺序。如果运行足够的时间,您将看到调用以不同的顺序进行打印。当执行goroutine时,由于它们是并发操作,因此无法保证它们将何时执行和/或完成。您需要使用各种标准库程序包或通道本身来同步并发运行的goroutine的执行。
类D 主要方法是 Bean配置文件是 程序的输出为:
我正在比较算法(前n个数之和)的顺序和并行性能(使用ForkJoinPool): 我试着用不同的NumLoop来获得不同的值,但顺序法总是表现得更好,而且也是按3-4的顺序。 考虑到阵列大小并不是那么小,并行版本在这里的性能不应该更好吗。
我无法确定spring security在何时何地执行身份验证管理器。我的意思是,certian过滤器按如下顺序执行: 但是当身份验证提供者对提供的用户名和密码进行身份验证时,我的意思是问下面这些过滤器是身份验证提供者执行的。 问候贾延德拉