1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586 |
- // Copyright (C) 2013 Vicente Botet
- //
- // Distributed under the Boost Software License, Version 1.0. (See accompanying
- // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
- // B
- #include <boost/atomic.hpp>
- //#include <boost/log/trivial.hpp>
- #include <boost/chrono.hpp>
- #include <boost/chrono/chrono_io.hpp>
- #include <boost/thread.hpp>
- #include <boost/thread/condition_variable.hpp>
- typedef boost::chrono::high_resolution_clock Clock;
- typedef Clock::time_point TimePoint;
- inline TimePoint real_time_now()
- {
- return Clock::now();
- }
- class Foo {
- boost::atomic<bool> m_is_exiting;
- TimePoint m_next_tick_time;
- public:
- bool is_exiting() const
- {
- return m_is_exiting;
- }
- TimePoint spawn_tasks() // note that in my app, this call takes more time than here
- {
- using namespace boost::chrono;
- const TimePoint now = real_time_now();
- if (m_next_tick_time < now) {
- m_next_tick_time = now + seconds(1);
- //BOOST_LOG_TRIVIAL(info) << "TICK!";
- }
- return m_next_tick_time;
- }
- };
- int main()
- {
- using namespace boost::chrono;
- static const milliseconds MIN_TIME_TASKS_SPAWN_FREQUENCY = milliseconds(1);
- //microseconds(1); // THE SHORTER THE QUICKER TO REPRODUCE THE BUG
- boost::condition_variable m_task_spawn_condition;
- Foo foo;
- boost::mutex main_thread_mutex;
- boost::unique_lock < boost::mutex > main_thread_lock(main_thread_mutex);
- //BOOST_LOG_TRIVIAL(info) << "[TaskScheduler::run_and_wait] Scheduling loop - BEGIN";
- int i =11;
- while (i--)
- {
- const TimePoint next_task_spawn_time = foo.spawn_tasks();
- const TimePoint now = real_time_now();
- const TimePoint next_minimum_spawn_time = now + MIN_TIME_TASKS_SPAWN_FREQUENCY;
- const TimePoint next_spawn_time = next_task_spawn_time > TimePoint()
- && next_task_spawn_time < next_minimum_spawn_time
- ? next_task_spawn_time : next_minimum_spawn_time;
- const TimePoint::duration wait_time = next_spawn_time - now;
- if (wait_time > wait_time.zero()) {
- // BOOST_LOG_TRIVIAL(trace) << "WAIT TIME: " << wait_time; // UNCOMMENT THIS: MAKES IT WORKS. WAT??????
- boost::this_thread::sleep_for(boost::chrono::seconds(1));
- std::cout << next_spawn_time << std::endl;
- m_task_spawn_condition.wait_until(
- main_thread_lock,
- next_spawn_time); // DON'T WORK: WILL WAIT IF next_spawn_time is too close!
- }
- }
- }
|