Method notifyAsyncRenderWork

tsunami/engine/asyncnotify.go:14–31

()

const NotifyMaxDebounceTime = 2 * time.Millisecond

func (c *ClientImpl) notifyAsyncRenderWork() {
	c.notifyOnce.Do(func() {
		c.notifyWakeCh = make(chan struct{}, 1)
		go c.asyncInitiationLoop()
	})

	nowNs := time.Now().UnixNano()
	c.notifyLastEventNs.Store(nowNs)
	// Establish batch start if there's no active batch.
	if c.notifyBatchStartNs.Load() == 0 {
		c.notifyBatchStartNs.CompareAndSwap(0, nowNs)
	}
	// Coalesced wake-up.
	select {
	case c.notifyWakeCh <- struct{}{}:
	default:
	}
}

func (c *ClientImpl) asyncInitiationLoop() {
	var (