QT多线程与进度条显示

2020-05-16

在Qt里，线程相关的类有：

QThread 线程

QMutex 互斥锁

QSemaphore 信号量

创建线程：

class MyThread : public QThread
{ 
	Q_OBJECT
public: 
	MyThread(QObject *parent);
    ~MyThread(); void run();   // 线程的入口函数
};

启动线程:

1 2	MyTask* m_task = new MyTask(); m_task‐>start();//启动

回收线程：

1	m_task‐>wait();

工作线程的概念：

工作线程：就是一个普通的线程，区别于“界面线程”。当一个事件处理可能需要较长时间，就创建一个线程来完成它，以免界面卡死。

接下来，采用一个示例：采用线程方式模拟传送一个文件，并在另外一个界面实时显示任务进度。

步骤：

(1)打开QT设计师，设计传送界面和进度条显示界面

(2) 创建、启动一个工作线程

(3) 显示一个进度条或等待对话框

(4) 启动一个定时器，定时查询工作线程的进度和状态，在其完成之后，填满进度条、结束等待。

主程序：

#include "test.h"
#include <QtGui/QApplication>

int main(int argc, char *argv[])
{
	QApplication a(argc, argv);
	Test w;
	w.show();
	return a.exec();
}

SendDlg.h文件：

#ifndef SENDDLG_H
#define SENDDLG_H

#include <QDialog>
#include "ui_SendDlg.h"
#include "SendTask.h"

class SendDlg : public QDialog
{
	Q_OBJECT

public:
	SendDlg(const QString& filepath, QWidget *parent = 0);
	~SendDlg();


	virtual void timerEvent (QTimerEvent * event);
private:
	Ui::SendDlg ui;

	SendTask* m_task; // 工作线程
	int m_timerId; // 定时器ID
};

#endif // SENDDLG_H

SendDlg.c文件：

#include "SendDlg.h"
#include "GBK.h"

SendDlg::SendDlg(const QString& filepath, QWidget *parent)
	: QDialog(parent)
{
	ui.setupUi(this);

	// 把中文转换一下
	string gbk_filepath = GBK::FromUnicode(filepath);

	// 创建工作线程
	m_task = new SendTask(NULL);
	m_task->Create(gbk_filepath.c_str());

	//
	m_timerId = startTimer(500);
}

SendDlg::~SendDlg()
{

}


void SendDlg::timerEvent ( QTimerEvent * event )
{
	//
	if(event->timerId() == m_timerId)
	{
		// 获取工作线程的当前状态和进度，并显示
		int status = m_task->GetStatus();
		int progress = m_task->GetProgress();
		ui.progressBar->setValue(progress);

		if(status == 1)
		{
			// 销毁线程
			m_task->Destroy();
			delete m_task;
			killTimer(m_timerId); // 关闭定时器
			this->accept(); // 关闭对话框
		}
	}
}

SendTask.h文件：

#ifndef SENDTASK_H
#define SENDTASK_H

#include <QThread>

class SendTask : public QThread
{
	Q_OBJECT

public:
	SendTask(QObject *parent);
	~SendTask();

	// 创建与销毁线程
	int Create(const char* filename);
	void Destroy();

	int GetStatus();
	int GetProgress();

private:
	// 线程的入口函数
	void run();   
	
private:
	char m_filepath[128];
	int m_filesize; // 文件的总字节数 
	int m_bytesread; // 读取并处理了多少字节
	int m_status; // 任务的状态
};

#endif // SENDTASK_H

SendTask.c文件：

#include "SendTask.h"
#include <string.h>
#include <QDebug>

SendTask::SendTask(QObject *parent)
	: QThread(parent)
{

}

SendTask::~SendTask()
{

}

int SendTask::Create(const char* filename)
{
	strcpy(m_filepath, filename);
	m_filesize = 0;
	m_bytesread = 0;
	m_status = 0;

	start(); // 运行线程
	return 0;
}

void SendTask::Destroy()
{
	wait();
}

int SendTask::GetStatus()
{
	return m_status;
}

int SendTask::GetProgress()
{
	if(m_filesize <= 0) return 0;

	return m_bytesread * 100 / m_filesize;
}

// 线程的主函数
void SendTask::run()
{
	FILE* fp = fopen(m_filepath, "rb");
	if(!fp)
	{
		m_status = -1; // 状态： 发生错误
		return ;
	}

	// 获取文件大小
	fseek(fp, 0, SEEK_END);
	m_filesize = ftell(fp);
	fseek(fp, 0, SEEK_SET);

	// 模拟发送
	char buf[1024];
	int part = 0;
	while(1)
	{
		int n = fread(buf, 1, 1024, fp);
		if(n <=0)
		{
			break;
		}

		m_bytesread += n;

		qDebug() << "Read: " << m_bytesread;

		// 每隔一定时间， sleep一次
		part += n;
		if(part > 1024 * 32)
		{
			QThread::msleep(50); // 模拟一下
			part = 0;
		}
	}
	fclose(fp);
	m_status = 1; // 状态：已经完成
	qDebug() << "Complete ........" ;

}

test.h文件：

#ifndef TEST_H
#define TEST_H

#include <QtGui/QMainWindow>
#include "ui_test.h"

class Test : public QMainWindow
{
	Q_OBJECT

public:
	Test(QWidget *parent = 0, Qt::WFlags flags = 0);
	~Test();

private slots:
	int OnBtnSelect(); // 选择文件
	int OnSend(); // 点发送按钮

private:
	Ui::Test_Class ui;
};

#endif // TEST_H

test.c文件：

#include "test.h"
#include <QFileDialog>
#include "SendDlg.h"

Test::Test(QWidget *parent, Qt::WFlags flags)
	: QMainWindow(parent, flags)
{
	ui.setupUi(this);

	// 按钮
	connect(ui.btnSelect, SIGNAL(clicked()), 
		this, SLOT(OnBtnSelect()));
	connect(ui.btnSend, SIGNAL(clicked()),
		this, SLOT(OnSend()));

}

Test::~Test()
{

}

int Test::OnBtnSelect()
{
	// 选择文件
	QString filepath = QFileDialog::getOpenFileName(this, "选择文件");
	if(filepath.length() > 0)
	{
		ui.textFile->setText(filepath);
	}
	return 0;
}

int Test::OnSend()
{
	QString filepath = ui.textFile->text();
	SendDlg dlg(filepath, this);
	dlg.exec();
	return 0;
}

实现情况：