星雀集团
进入errgroup.starlark组。 允许starlark线程生成go例程。 每个go例程都可以选择合并并限制速率。 要去的论点被冻结。 Wait返回按调用顺序排序的元组。
def square ( x ):
return x * x
def square_all ( vs ):
# Create a group of 10 go routines, limited every 10ms with a burst of 10.
g = group ( n = 10 , every = "10ms" , burst = 10 )
for i in vs :
g . go ( square , i ) # args[1:] and kwargs passed to arg[0]
return g . wait ()