Ревью

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

Для новичков, кто еще не видел эту рубрику. В рубрике #ревью мы выкладываем сюда отрывок кода, а вы в комментах по существу говорите, что в этом коде не так и как бы вы это исправили. Как бы вы это делали на реальном ревью в своем проекте. Того, кто найдет больше всего недостатков, я завтра упомяну в итоговом посте-компиляции из всех найденных проблем.

Вот собственно код:

struct Task {
  void Execute() {
    // pretend that this is very long calculations
    std::this_thread::sleep_for(std::chrono::seconds(2));
  }
}; 

void WorkingThread(std::deque<Task> queue) {
  std::mutex mtx;
  mtx.lock();
  while (!queue.empty()) {
    auto elem = queue.front();
    queue.pop_front();
    elem.Execute();
    lck.unlock();
    // to get other threads opportunity to work
    std::this_thread::sleep_for(std::chrono::milliseconds(1));
    lck.lock();
  }
}

int main() {
  std::deque<Task> queue(10);
  std::thread thr1{WorkingThread, queue}, thr2{WorkingThread, queue};
}

Чего ждем? Айда в комменты поливать г ревьюить код.

Ask for objective critique. Stay cool.