Commit a7194295 authored by gabime's avatar gabime

fix queue

parent 31315db7
...@@ -104,8 +104,7 @@ private: ...@@ -104,8 +104,7 @@ private:
std::mutex mutex_; std::mutex mutex_;
std::condition_variable item_pushed_cond_; std::condition_variable item_pushed_cond_;
std::condition_variable item_popped_cond_; std::condition_variable item_popped_cond_;
static constexpr auto one_hour = std::chrono::seconds(3); static constexpr auto one_hour = std::chrono::hours(1);
}; };
} }
......
...@@ -35,7 +35,6 @@ inline void bench(const std::string& fn_name, const std::chrono::milliseconds &d ...@@ -35,7 +35,6 @@ inline void bench(const std::string& fn_name, const std::chrono::milliseconds &d
auto now = the_clock::now(); auto now = the_clock::now();
if (now - start_time >= duration) if (now - start_time >= duration)
break; break;
auto p = now - lastPrintTime;
if (now - lastPrintTime >= print_interval) if (now - lastPrintTime >= print_interval)
{ {
std::cout << fn_name << ": " << format(counter) << " per sec" << std::endl; std::cout << fn_name << ": " << format(counter) << " per sec" << std::endl;
...@@ -55,4 +54,4 @@ inline void bench(const std::string& fn_name, const std::function<void() >& fn) ...@@ -55,4 +54,4 @@ inline void bench(const std::string& fn_name, const std::function<void() >& fn)
std::cout << fn_name << ": " << duration_cast<milliseconds>(delta).count() << " ms" << std::endl; std::cout << fn_name << ": " << duration_cast<milliseconds>(delta).count() << " ms" << std::endl;
} }
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment