К вопросу об организации взаимодействия пула производителей и одного потребителя

[m_ax]

Стоп, так у вас два мьютекса вместо одного?
Зачем, достаточно одного мьютекса.

Да, два   Один для очереди, другой для condition_variable) А одним можно?  

Аааа))) Дошло 

[m_ax]

Спасибо, понял) Исправил)

[Old]

Код

C++ (Qt)
    void worker()
    {
        while (!m_is_stop)
        {
            {
                std::unique_lock<std::mutex> lock(m_mutex);
                m_loop_cv.wait(lock, [&]()
                {
                    return !m_queue.empty() || m_is_stop;
                });
            }
 
            if (m_is_stop)
                return;
 
            std::function<void()> work_function([](){});
 
            {
                // std::lock_guard<std::mutex> lock(m_mutex);  <<< и так золочен
                // if (!m_queue.empty())  <<< тут точно не пусто - проверено в wait
                {
                    work_function = std::move(m_queue.front());
                    m_queue.pop();
                }
            }
           // Разлочиваем и запускаем работу
           lock.unlock();
 
           work_function();
        }
    }
 

[m_ax]

Нет..

Код

C++ (Qt)
while (!m_is_stop)
        {
            {
                std::unique_lock<std::mutex> lock(m_mutex);
                m_loop_cv.wait(lock, [&]()
                {
                    return !m_queue.empty() || m_is_stop;
                });
            }
            // <<< Здесь lock уже откинулся и освободил m_mutex 
 
            if (m_is_stop)
                return;
 
            std::function<void()> work_function([](){});
 
            {
                // std::lock_guard<std::mutex> lock(m_mutex);  <<< и так золочен 
                // if (!m_queue.empty())  <<< тут точно не пусто - проверено в wait
                {
                    work_function = std::move(m_queue.front());
                    m_queue.pop();
                }
            }
           // Разлочиваем и запускаем работу
           lock.unlock();
 
           work_function();
        }
    }
 

Можно тогда сделать так (чтоб дважды m_mutex не захватывать)

Код

C++ (Qt)
void worker()
    {
        while (!m_is_stop)
        {
            std::unique_lock<std::mutex> lock(m_mutex);
             m_loop_cv.wait(lock, [&]()
             {
                    return !m_queue.empty() || m_is_stop;
             });
 
 
            if (m_is_stop)
                return;
 
            std::function<void()> work_function(m_queue.front());
            m_queue.pop();
            lock.unlock();
 
           work_function();
        }
    }
 

[Old]

// <<< Здесь lock уже откинулся и освободил m_mutex

Нет.
wait работает следующим образом (псевдокод):

Код

C++ (Qt)
wait( mutex m )
{
  m.unlock()
  yield()
  m.lock()
}
 

Т.е. он освобождает мьютекс и отдает управление планировщику, говоря производителям: я освободил мьютекс и жду когда вы накидаете мне в очередь работы. Производитель теперь может захватить мьютекс и положить работу в очередь. Затем он сигналит и освобождает мьютекс. Когда планировщик разбудит нить, управление вернется после yield, далее wait опять захватит мьютикс и завершится. Мьютекс снова захвачен, мы можем работать с очередью.

[Old]

Можно тогда сделать так (чтоб дважды m_mutex не захватывать)

Так это тот же вариант, который получается с моими комментариями.

UPDATE. Ааа, увидел что локер был в {}. Да последний вариант - нормальный.

[m_ax]

Да последний вариант - нормальный.

Исправил 

[Igors]

Код

C++ (Qt)
auto task_ptr = std::make_shared<std::packaged_task<decltype(work_function())()>>(std::forward<F>(work_function));
 

Не стоит так гнаться за модой   Это лишь засирает мозги и отвлекает программиста от содержательной работы

[Old]

Код

C++ (Qt)
auto task_ptr = std::make_shared<std::packaged_task<decltype(work_function())()>>(std::forward<F>(work_function));
 

Не стоит так гнаться за модой  Это лишь засирает мозги и отвлекает программиста от содержательной работы

Это не мода, а более общее решение, которое позволяет легко написать код как для случая, когда нужно дождаться завершения всех работ в пуле, так и для ожидания завершения только части работ. Ведь один и тот же пул может использоваться для разных типов работ, завершение каких-то работ нужно ждать в одном месте, завершение других  в другом.

[ViTech]

Хотел поинтересоваться:

Код

C++ (Qt)
class thread_pool
{
...
private:
...
    std::list<std::shared_ptr<std::thread>> m_threads;
...
};
 

Почему shared_ptr использовали? Какой ход мыслей был, или на автомате? Мне  в исследовательских целях интересно .

[m_ax]

Хотел поинтересоваться:

Код

C++ (Qt)
class thread_pool
{
...
private:
...
    std::list<std::shared_ptr<std::thread>> m_threads;
...
};
 

Почему shared_ptr использовали? Какой ход мыслей был, или на автомате? Мне  в исследовательских целях интересно .

Я по привычке, поскольку std::thread - некопируемый объект. А я все некопируемые объекты в контейнерах по указателю храню.. (Мало ли что  )
А std::shared_ptr использовал чтоб не заморачиваться с их ручным удалением в деструкторе thread_poolа 

[ViTech]

Я по привычке, поскольку std::thread - некопируемый объект. А я все некопируемые объекты в контейнерах по указателю храню.. (Мало ли что  )
А std::shared_ptr использовал чтоб не заморачиваться с их ручным удалением в деструкторе thread_poolа 

Ок, спасибо за ответ .

[Old]

Я по привычке, поскольку std::thread - некопируемый объект. А я все некопируемые объекты в контейнерах по указателю храню.. (Мало ли что  )

Ну так он перемещаемый.

Код

C++ (Qt)
vector<thread> m_threads;
 

и все.

[m_ax]

Я по привычке, поскольку std::thread - некопируемый объект. А я все некопируемые объекты в контейнерах по указателю храню.. (Мало ли что  )

Ну так он перемещаемый.

Код

C++ (Qt)
vector<thread> m_threads;
 

и все.

Да, верно, перемещаемый)

PS Кстатии в boost::thread_group тоже используют список с указателями на thread 

[Old]

PS Кстатии в boost::thread_group тоже используют список с указателями на thread 

Это легаси.
boost::thread появился в далеком 2001 году, когда о move-семантики даже не задумывались.