QMutex: уничтожение заблокированного мьютекса - PullRequest
Новая
       55

QMutex: уничтожение заблокированного мьютекса

0 голосов
/ 20 февраля 2019

Учитывая следующий код: 

#include <chrono>
#include <ctime>
#include <functional>
#include <iostream>
#include <thread>
#include <utility>

#include <QFuture>
#include <QMutex>
#include <QWaitCondition>
#include <QtConcurrent>

class Async
{
public:
    Async() = default;
    Async(const Async&) = delete;
    Async(Async&&) = delete;

    ~Async() = default; //{ m_mutex.unlock(); }

    Async& operator=(const Async&) = delete;
    Async& operator=(Async&&) = delete;

    template<typename t_result>
    QFuture<bool> operator()(
          std::function<t_result()>&& p_function,
          std::chrono::milliseconds p_timeout,
          t_result* p_result)
    {
        QtConcurrent::run([this, p_function, p_result]() {
            *p_result = p_function();
            std::cout << time(nullptr) << " waking" << std::endl;
            m_cond.wakeAll();
    });

    return QtConcurrent::run([this, p_timeout]() {
           std::cout << time(nullptr) << " starting to wait for "
                     << p_timeout.count() << " ms" << std::endl;
           m_mutex.lock();
           bool wait =
               m_cond.wait(&m_mutex, 
                           static_cast<unsigned 
                                       long>(p_timeout.count()));
           std::cout << time(nullptr)
                     << ", finished waiting = " 
                     << (wait ? "T" : "F") 
                     << std::endl;
           if (wait) {
               return false;
           }
           return true;
    });
  }

private:
    QMutex m_mutex;
    QWaitCondition m_cond;
};

int main()
{
  Async async;

  char letter = 'z';

  std::function<char()> f1 = []() -> char {
      std::this_thread::sleep_for(std::chrono::seconds(4));
      return 'a';
  };

  std::cout << "1: " << time(nullptr) << std::endl;
  QFuture<bool> result =
    async(std::move(f1), std::chrono::milliseconds(3999), 
          &letter);

  std::cout << "2: " << time(nullptr) << std::endl;

  std::this_thread::sleep_for(std::chrono::seconds(8));

  std::cout << "3: " << time(nullptr) << std::endl;

  if (result.result()) {
    std::cout << "timeout, letter = " << letter;
  } else {
    std::cout << "NO timeout, letter = " << letter;
  }
  std::cout << std::endl;

  return 0;
}

Наконец ... 8), когда я запускаю его, все cout печатают то, что ожидается, но я получаю QMutex: destroying locked mutex в конце исполнения.Поскольку я получаю сообщение finished waiting, m_cond.wait выполняется, поэтому (я думал), m_mutex будет разблокировано.Но это не так.

Если я использую ~Async() { m_mutex.unlock(); }, я не получаю сообщение, но я не думаю, что это должно быть сделано таким образом.

Может ли кто-нибудь, пожалуйста, объяснить, почему мьютекс не используетсявыпущен?

Большое спасибо!

Ответы [ 2 ]

0 голосов
/ 21 февраля 2019

Когда ожидаемое ожидание переменной состояния с использованием исключительного мьютекса, оно блокирует мьютекс, когда ожидание закончено (тайм-аут или нет).

Это означает, что вы должны явно разблокировать мьютекс 

bool wait = m_cond.wait(&m_mutex,static_cast<unsigned long>(p_timeout.count()));
m_mutex.unlock();
if (wait) {
    return false;
}
return true;
0 голосов
/ 20 февраля 2019

Со страницы Qt QMutex :

Предупреждение: уничтожение заблокированного мьютекса может привести к неопределенному поведению.

...