fix(registry/consul): fix concurrency issues and improve performance

[lftk]

修复了一些并发相关的问题：

1. Registry 锁的范围太大，比如 Watch 对整个函数加锁，不能同时处理多个（不同的）Service；

kratos/contrib/registry/consul/registry.go

Lines 183 to 185 in 5087366

	func (r *Registry) Watch(ctx context.Context, name string) (registry.Watcher, error) {
	r.lock.Lock()
	defer r.lock.Unlock()

2. 相同的 Service 没有共享 resolve，只要 Watch 就会新开一个 resolve 协程；

kratos/contrib/registry/consul/registry.go

Lines 211 to 213 in 5087366

	if err := r.resolve(ctx, set); err != nil {
	return nil, err
	}

3. Client 注销任一 Service 都会直接 cancel 掉 Client.ctx，导致所有的 heartbeat 协程退出；

kratos/contrib/registry/consul/client.go

Lines 246 to 249 in 5087366

	func (c *Client) Deregister(_ context.Context, serviceID string) error {
	defer c.cancel()
	return c.cli.Agent().ServiceDeregister(serviceID)
	}

4. 在 Watch 时，由于 w 先被添加到 set 中，然后才会写入 services event，如果在两步中间正好遇到之前的 resolve 在 broadcast，209行的写入则会被卡住（w 还没有返回，不会有调用者主动调用 Next 消费）。

kratos/contrib/registry/consul/registry.go

Lines 196 to 214 in 5087366

	// init watcher
	w := &watcher{
	event: make(chan struct{}, 1),
	}
	w.ctx, w.cancel = context.WithCancel(ctx)
	w.set = set
	set.lock.Lock()
	set.watcher[w] = struct{}{}
	set.lock.Unlock()
	ss, _ := set.services.Load().([]*registry.ServiceInstance)
	if len(ss) > 0 {
	// If the service has a value, it needs to be pushed to the watcher,
	// otherwise the initial data may be blocked forever during the watch.
	w.event <- struct{}{}
	}
	if err := r.resolve(ctx, set); err != nil {
	return nil, err
	}
	return w, nil

5. 其他，提前判断 ctx.Err() 避免做冗长的无用功、sleepCtx 等。