76 lines
1.4 KiB
C++
76 lines
1.4 KiB
C++
|
#include "Thread.h"
|
||
|
|
#include "ThreadPool.h"
|
||
|
|
#include <QDebug>
|
||
|
|
|
||
|
|
Thread::Thread(int id, ThreadPool *pool, QObject *parent) :
|
||
|
|
QObject(parent),
|
||
|
|
m_threadPool(pool),
|
||
|
|
m_id(id)
|
||
|
|
{
|
||
|
|
|
||
|
|
moveToThread(&m_thread);
|
||
|
|
connect(&m_thread, &QThread::started, [this](){
|
||
|
|
emit threadStarted();
|
||
|
|
run();
|
||
|
|
});
|
||
|
|
connect(&m_thread, &QThread::finished, [this](){
|
||
|
|
emit threadStoped();
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
Thread::~Thread()
|
||
|
|
{
|
||
|
|
if (isStarted())
|
||
|
|
stop();
|
||
|
|
}
|
||
|
|
|
||
|
|
int Thread::id() const
|
||
|
|
{
|
||
|
|
return m_id;
|
||
|
|
}
|
||
|
|
|
||
|
|
bool Thread::start()
|
||
|
|
{
|
||
|
|
bool ok = false;
|
||
|
|
if (!isStarted()) {
|
||
|
|
m_thread.start();
|
||
|
|
ok = true;
|
||
|
|
}
|
||
|
|
return ok;
|
||
|
|
}
|
||
|
|
|
||
|
|
bool Thread::stop()
|
||
|
|
{
|
||
|
|
bool ok = false;
|
||
|
|
if (isStarted()) {
|
||
|
|
m_thread.quit();
|
||
|
|
m_thread.wait();
|
||
|
|
emit threadStoped();
|
||
|
|
ok = true;
|
||
|
|
}
|
||
|
|
return ok;
|
||
|
|
}
|
||
|
|
|
||
|
|
bool Thread::isStarted() const
|
||
|
|
{
|
||
|
|
return m_thread.isRunning();
|
||
|
|
}
|
||
|
|
|
||
|
|
void Thread::run()
|
||
|
|
{
|
||
|
|
// 就是抢任务这一块出问题了，任务输入的太快
|
||
|
|
while (true) {
|
||
|
|
QMutexLocker lock(&(m_threadPool->m_mutex));
|
||
|
|
// qDebug() << QString("线程%1 进入等待！").arg(m_id);
|
||
|
|
m_threadPool->m_cond.wait(lock.mutex());
|
||
|
|
// qDebug() << QString("线程%1 被唤醒！").arg(m_id);
|
||
|
|
if (!m_threadPool->is_running && m_threadPool->m_tasks.empty()) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
m_task = m_threadPool->m_tasks.front();
|
||
|
|
m_threadPool->m_tasks.pop();
|
||
|
|
m_task.run();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|