refactor
This commit is contained in:
@ -164,7 +164,8 @@ private:
|
|||||||
event_notify_.notify_all();
|
event_notify_.notify_all();
|
||||||
lock.unlock();
|
lock.unlock();
|
||||||
|
|
||||||
for (auto retry{0U}; size > max_queue_size && retry < max_queue_retry &&
|
for (std::uint8_t retry{0U};
|
||||||
|
size > max_queue_size && retry < max_queue_retry &&
|
||||||
not get_stop_requested();
|
not get_stop_requested();
|
||||||
++retry) {
|
++retry) {
|
||||||
lock.lock();
|
lock.lock();
|
||||||
|
Reference in New Issue
Block a user