Boost C++ Application Development Cookbook - Second Edition

How to do it...

We do not need to block at all! Let's take a closer look at the example. All we need to do is to post four fill_data tasks and make the last finished task call compute_send_data(data).

1. We'll need the tasks_processor class from the first recipe; no changes to it need to be done.
2. Instead of a barrier, we'll be using the atomic variable:

#include <boost/atomic.hpp> typedef boost::atomic<unsigned int> atomic_count_t; 

3. Our new runner function will look like this:

void clever_runner(        std::size_t thread_index,        std::size_t iteration,        atomic_count_t& counter,        data_t& data){    fill_data(data.at(thread_index));    if (++counter != data_t::static_size) {        return;    }    compute_send_data(data);    if (++iteration == 1000) { // Exiting, because ...