context *
round_robin::pick_next() noexcept {
- context * victim{ nullptr };
+ context * victim = nullptr;
if ( ! rqueue_.empty() ) {
victim = & rqueue_.front();
rqueue_.pop_front();
void
round_robin::suspend_until( std::chrono::steady_clock::time_point const& time_point) noexcept {
if ( (std::chrono::steady_clock::time_point::max)() == time_point) {
- std::unique_lock< std::mutex > lk( mtx_);
+ std::unique_lock< std::mutex > lk{ mtx_ };
cnd_.wait( lk, [&](){ return flag_; });
flag_ = false;
} else {
- std::unique_lock< std::mutex > lk( mtx_);
+ std::unique_lock< std::mutex > lk{ mtx_ };
cnd_.wait_until( lk, time_point, [&](){ return flag_; });
flag_ = false;
}
void
round_robin::notify() noexcept {
- std::unique_lock< std::mutex > lk( mtx_);
+ std::unique_lock< std::mutex > lk{ mtx_ };
flag_ = true;
lk.unlock();
cnd_.notify_all();