QMUTEX:销毁锁定的静音
QMutex: destroying locked mutex
给定以下代码:
#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(); }
,我不会收到消息,但是我认为应该这样做。
请任何人都可以解释为什么互不释放?
非常感谢!
当使用独家哑光在条件变量上可运行的等待时,等待结束时,它将锁定在utex上(超时)。
这意味着您必须显式解锁Mutex
bool wait = m_cond.wait(&m_mutex,static_cast<unsigned long>(p_timeout.count()));
m_mutex.unlock();
if (wait) {
return false;
}
return true;
来自qt qmutex页面:
警告:销毁锁定的静音可能会导致不确定的行为。
相关文章:
- 如何找到锁定Linux futex的C++行
- G锁定铸造到基础上会释放模拟行为
- 如何检查线程是否锁定
- 如何在C++中找到active directory中禁用和锁定的窗口帐户
- 我应该在锁定TBitmap画布后解锁它吗
- C++ 11 中的锁定是否保证访问数据的新鲜度?
- 在两个线程上读/写 64 位,无互斥/锁定/原子
- 如何在实时应用程序中锁定线程
- 在 lambda 中锁定 std::shared_ptr 的复制操作
- 使用简单两相锁定的并发程序
- 锁定来自其他线程的类成员
- 他们如何将红外锁定像素转换为镜头前方 1m 的正常平面上的位置
- 同一互斥锁顺序上的锁定和解锁是否一致?
- 共享内存的升压容器是否实现锁定?
- 当只有一个线程主要使用该对象而其他线程很少使用它时,如何最小化该对象的互斥锁锁定?
- 如何在 x86 处理器上实现"锁定添加"
- MCS 锁定实现的问题
- QMUTEX:销毁锁定的静音
- QtCore,QMutex 类,锁定功能 - 堆栈溢出故障
- 在析构函数中锁定QMutex