boost::atomic<bool> m_is_exiting;

TimePoint m_next_tick_time;

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;

}

{

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!

}

}