Добавит ь возможность управлять емкостью очереди и отказывать на отправку в очередь, когда она переполнена. С определенным типом ошибки.
WithQueueCapacity(10000)
Примерно так в конструкторе. При Stop() и дренаже тоже декремент.
Это атомик число. Инкрементится когда срабатывает Add() и декрементится когда выполняется queue. Done().
Добавит ь возможность управлять емкостью очереди и отказывать на отправку в очередь, когда она переполнена. С определенным типом ошибки.
WithQueueCapacity(10000)
Примерно так в конструкторе. При Stop() и дренаже тоже декремент.
Это атомик число. Инкрементится когда срабатывает Add() и декрементится когда выполняется queue. Done().