就像我们在”Goroutines”章节中提到了,Go语言会帮你处理goroutine到系统线程上。它使用的算法被称为工作窃取策略(work stealing strategy)。这是什么意思?

首先,让我们看看在许多处理器之间共享工作的天然策略,有时称为公平调度。为了确保所有处理器的平均利用率,我们可以在所有可用处理器之间平均分配负载。想象一下,有n个处理器和x个任务需要执行。在公平调度策略中,每个处理器都会得到x/n个任务:

<Schedule Task 1>
<Schedule Task 2>
<Schedule Task 3>
<Schedule Task 4>

不幸的是,这种方法存在问题。 如果你还记得“Goroutines”章节中我们提到Go使用fork-join模型来并发建模。在fork-join范例中,任务可能依赖于另一个,并且事实证明,在处理器之间分裂它们可能会导致其中一个处理器未充分利用。不仅如此,它还可能导致局部性缓存较差,因为在其他处理器上调度需要相同的数据任务。我们来看一个例子。

考虑一个程序,可以产生前面所述的工作分配。 如果第2项任务比第1项和第3项结合需要更长的时间,会发生什么?

无论a和b之间的时间有多久,处理器一会闲置。

如果任务之间存在相互依存关系,如果分配给一个处理器的任务需要分配给另一个处理器的任务的结果,会发生什么情况? 例如,如果任务一依赖任务4呢?

在这种情况下,处理器1完全空闲,而任务2和4正在计算中。 虽然处理器1在任务1中被阻塞,处理器2在任务2中被占用,但处理器1可能已经在处理任务4以解除其自身阻塞。

最后编辑: kuteng  文档更新时间: 2021-01-02 17:30   作者:kuteng