diff options
Diffstat (limited to 'include/dumb_timer_queue.h')
| -rw-r--r-- | include/dumb_timer_queue.h | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/include/dumb_timer_queue.h b/include/dumb_timer_queue.h index ebb8bb1..86ec7c1 100644 --- a/include/dumb_timer_queue.h +++ b/include/dumb_timer_queue.h @@ -29,19 +29,17 @@ namespace crow k.first = nullptr; if (!self) return; - self->mutex_.lock(); + unsigned int index = (unsigned int)(k.second - self->step_); if (index < self->dq_.size()) self->dq_[index].second = nullptr; - self->mutex_.unlock(); } key add(std::function<void()> f) { - mutex_.lock(); dq_.emplace_back(std::chrono::steady_clock::now(), std::move(f)); int ret = step_+dq_.size()-1; - mutex_.unlock(); + CROW_LOG_DEBUG << "timer add inside: " << this << ' ' << ret ; return {this, ret}; } @@ -50,7 +48,7 @@ namespace crow { if (!io_service_) return; - mutex_.lock(); + auto now = std::chrono::steady_clock::now(); while(!dq_.empty()) { @@ -60,13 +58,12 @@ namespace crow if (x.second) { CROW_LOG_DEBUG << "timer call: " << this << ' ' << step_; - //io_service_->post(std::move(x.second)); + // we know that timer handlers are very simple currenty; call here x.second(); } dq_.pop_front(); step_++; } - mutex_.unlock(); } void set_io_service(boost::asio::io_service& io_service) @@ -82,7 +79,6 @@ namespace crow int tick{5}; boost::asio::io_service* io_service_{}; std::deque<std::pair<decltype(std::chrono::steady_clock::now()), std::function<void()>>> dq_; - std::mutex mutex_; int step_{}; }; } |