Dropped items

[blanchg]

I realize this is 4-5 years old but for anyone that follows.

Items that are added while a batch is executing the callback function due to timer will be silently dropped.

This is because the callback function called by the timer isn't safeguarded by the mutex. To fix

modify the timer handler in the run() func

case <-timer.C:
	bc.mutex.Lock()
	defer bc.mutex.Unlock()
	bc.callback(batch)
	if bc.input != nil {
		close(bc.input)
		bc.input = nil
	}
	return

Thanks!