refactor: eventPool get atomicity

[lyp256]

Proposed Changes:

当前 eventPool 实现在并发调用 GetN 时会导致死锁问题见 #228 。

重构了 eventPool 实现主要变更：

• 解决并发调用 GetN 导致死锁的问题
• eventPool 所有 Get API 支持 context.Context 支持由调用方终止阻塞等待

[mmaxiaolei]

整体看实现有点复杂。

把event直接用chan作为存储，然后getN()用lock+for select eventChan是不是会简洁一点？类似以下伪代码：

func (p *Pool) GetNContext(ctx context.Context, n int) ([]api.Event, bool) {
	p.lock.Lock()
	defer p.lock.Unlock()

	events := make([]api.Event, 0, n)
	for {
		select {
		case e := <-p.events:
			events = append(events, e)
			if len(events) == n {
				return events, true
			}
		case <-ctx.Done():
			return nil, false
		}
	}
}

[mmaxiaolei]

有足够的数量了，直接close(notifty.C)就可以了吧

[lyp256]

[lyp256]

整体看实现有点复杂。

把event直接用chan作为存储，然后getN()用lock+for select eventChan是不是会简洁一点？类似以下伪代码：

func (p *Pool) GetNContext(ctx context.Context, n int) ([]api.Event, bool) {
	p.lock.Lock()
	defer p.lock.Unlock()

	events := make([]api.Event, 0, n)
	for {
		select {
		case e := <-p.events:
			events = append(events, e)
			if len(events) == n {
				return events, true
			}
		case <-ctx.Done():
			return nil, false
		}
	}
}

这样实现的话，并发时后续 GetNContext 会被阻塞在 p.lock.Lock() 无法相应 context.Done()