|
|
@ -129,9 +129,11 @@ func (r *runnableGroup) Start(ctx context.Context) error {
|
|
|
|
r.startOnce.Do(func() {
|
|
|
|
r.startOnce.Do(func() {
|
|
|
|
defer close(r.startReadyCh)
|
|
|
|
defer close(r.startReadyCh)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 实际上是执行我们的 reconcile
|
|
|
|
// Start the internal reconciler.
|
|
|
|
// Start the internal reconciler.
|
|
|
|
go r.reconcile()
|
|
|
|
go r.reconcile()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 控制启动后的生命周期
|
|
|
|
// Start the group and queue up all
|
|
|
|
// Start the group and queue up all
|
|
|
|
// the runnables that were added prior.
|
|
|
|
// the runnables that were added prior.
|
|
|
|
r.start.Lock()
|
|
|
|
r.start.Lock()
|
|
|
|