当前位置： 首页 > news >正文

做试管网站注册网站的免费网址

news 2025/8/16 3:15:30
做试管网站,注册网站的免费网址,网站建设人员岗位设置,综合b2b电子商务网站有哪些一、多线程程序 QThread类提供了管理线程的方法：一个对象管理一个线程一般从QThread继承一个自定义类，重载run函数 1、实现程序 （1）创建项目，基于QDialog （2）添加类，修改基于QThr…

一、多线程程序

QThread类提供了管理线程的方法：
  • 一个对象管理一个线程
  • 一般从QThread继承一个自定义类，重载run函数

1、实现程序

在这里插入图片描述

（1）创建项目，基于QDialog

（2）添加类，修改基于QThread

在这里插入图片描述

#ifndef DICETHREAD_H
#define DICETHREAD_H#include <QThread>class DiceThread : public QThread
{Q_OBJECTprivate:int m_seq = 0;int m_diceValue;bool m_Paused = true;bool m_stop = false;public:explicit DiceThread();void diceBegin();void dicePause();void stopThread();protected:void run() Q_DECL_OVERRIDE;signals:void newValued(int seq, int diceValue);public slots:
};#endif // DICETHREAD_H

#include "dicethread.h"
#include <QTime>DiceThread::DiceThread()
{}void DiceThread::diceBegin()
{m_Paused = false;
}void DiceThread::dicePause()
{m_Paused = true;
}void DiceThread::stopThread()
{m_stop = true;
}void DiceThread::run()
{m_stop = false;m_seq = 0;qsrand(QTime::currentTime().second());while (!m_stop) {if(!m_Paused){m_diceValue = qrand()%6+1;m_seq++;emit newValued(m_seq, m_diceValue);}sleep(1);}quit();
}

（3）实现按钮功能

#include "dialog.h"
#include "ui_dialog.h"Dialog::Dialog(QWidget *parent) :QDialog(parent),ui(new Ui::Dialog)
{ui->setupUi(this);ui->btnStartThread->setEnabled(true);ui->btnStart->setEnabled(false);ui->btnStop->setEnabled(false);ui->btnStopThread->setEnabled(false);connect(&threadA, SIGNAL(started()),this, SLOT(on_threadAStarted()));connect(&threadA, SIGNAL(finished()),this, SLOT(on_threadAFinished()));connect(&threadA, SIGNAL(newValued(int,int)),this, SLOT(on_threadAnewValue(int,int)));
}Dialog::~Dialog()
{delete ui;
}void Dialog::closeEvent(QCloseEvent *event)
{if(threadA.isRunning()){threadA.stopThread();threadA.wait();}event->accept();
}void Dialog::on_btnStartThread_clicked()
{threadA.start();
}void Dialog::on_btnStart_clicked()
{threadA.diceBegin();
}void Dialog::on_btnStop_clicked()
{threadA.dicePause();
}void Dialog::on_btnStopThread_clicked()
{threadA.stopThread();
}void Dialog::on_btnClearText_clicked()
{ui->plainTextEdit->clear();
}void Dialog::on_threadAnewValue(int seq, int diceValue)
{ui->plainTextEdit->appendPlainText(QString::asprintf("第%d次投色子： 点数%d", seq, diceValue));
}void Dialog::on_threadAStarted()
{ui->labelStatus->setText("Thread状态：started");ui->btnStartThread->setEnabled(false);ui->btnStart->setEnabled(true);ui->btnStop->setEnabled(true);ui->btnStopThread->setEnabled(true);
}void Dialog::on_threadAFinished()
{ui->labelStatus->setText("Thread状态：finished");ui->btnStartThread->setEnabled(true);ui->btnStart->setEnabled(false);ui->btnStop->setEnabled(false);ui->btnStopThread->setEnabled(false);
}

在这里插入图片描述

二、互斥量

QMutex和QMutexLocker是基于互斥量的线程同步类
  • QMutex定义的实力是互斥量，主要提供了三个函数
    • lock()：锁定互斥量，如果另一个线程锁定了这个互斥量，将阻塞直到另一个解锁
    • unlock()：解锁一个互斥量
    • trylock()：尝试锁定一个互斥量，如果成功返回true，失败（其他线程已经锁定这个互斥量）返回false，不阻塞线程。
  • QMutexLocker简化了互斥量的处理
    • 构造一个函数接受一个互斥量作为参数，并将其锁定
    • 析构函数解锁该互斥量

1、实现程序

（1）拷贝上一个项目

（2）修改程序为直接读取

void DiceThread::readValue(int *seq, int *diceValue)
{*seq = m_seq;*diceValue = m_diceValue;
}void DiceThread::run()
{m_stop = false;m_seq = 0;qsrand(QTime::currentTime().second());while (!m_stop) {if(!m_Paused){m_diceValue = 50;msleep(50);m_diceValue = qrand();msleep(50);m_diceValue = m_diceValue%6+1;msleep(50);m_seq++;
//            emit newValued(m_seq, m_diceValue);}sleep(1);}quit();
}

void Dialog::on_TimerOut()
{int seq, diceValue;threadA.readValue(&seq, &diceValue);ui->plainTextEdit->appendPlainText(QString::asprintf("第%d次投色子： 点数%d", seq, diceValue));
}

在这里插入图片描述

（3）使用QMutex互斥量

void DiceThread::readValue(int *seq, int *diceValue)
{mMutex.lock();*seq = m_seq;*diceValue = m_diceValue;mMutex.unlock();
}void DiceThread::run()
{m_stop = false;m_seq = 0;qsrand(QTime::currentTime().second());while (!m_stop){if(!m_Paused){mMutex.lock();m_diceValue = 50;msleep(50);m_diceValue = qrand();msleep(50);m_diceValue = m_diceValue % 6 + 1;msleep(50);m_seq++;//            emit newValued(m_seq, m_diceValue);mMutex.unlock();}sleep(1);}quit();
}

在这里插入图片描述

（4）使用QMutexLocker

void DiceThread::readValue(int *seq, int *diceValue)
{QMutexLocker locker(&mMutex);*seq = m_seq;*diceValue = m_diceValue;
}

（5）使用QMutex.trylock

bool DiceThread::readValue(int *seq, int *diceValue)
{//    QMutexLocker locker(&mMutex);if(mMutex.tryLock()){*seq = m_seq;*diceValue = m_diceValue;mMutex.unlock();return true;}return false;
}

三、读写锁

QReadWriteLock提供了以下主要函数：
  • lockForRead()：只读方式锁定资源，如果有其他线程以写入方式锁定，这个函数会阻塞
  • lockForWrite()：以写入方式锁定资源，如果本线程或者其他线程以读取或写入锁定资源，则函数阻塞
  • unlock()：解锁
  • tryLockForRead()：是lockForRead非阻塞版本
  • tryLockForWrite()：是lockForWrite非阻塞版本
  • 读写锁同样有QReadLocker和QWriteLocker

四、条件变量QWaitCondition

QWaitCondition用于通知其他线程，如接收数据和处理数据之间通知。提供了一些函数：
  • wait(QMutex *lockedMutex)：进入等待状态，解锁互斥量lockMutex，被唤醒后锁定lockMutex并退出函数
  • wakeAll()：唤醒所有处于等待的线程，线程唤醒的顺序不确定，有操作系统调度策略决定
  • QakeOne()：唤醒一个处于等待状态的线程，唤醒哪个线程不确定，由操作系统调度策略决定

1、实现程序

在这里插入图片描述

（1）拷贝上一个项目

（2）使用QWaitCondition设置数据更新

#include "dicethread.h"
#include <QTime>
#include <QWaitCondition>
#include <QMutex>int m_seq = 0;
int m_diceValue;
bool m_stop = false;
QMutex m_Mutex;
QWaitCondition waitCondition;ProducerThread::ProducerThread()
{}void ProducerThread::stopThread()
{m_stop = true;
}void ProducerThread::run()
{m_stop = false;m_seq = 0;qsrand(QTime::currentTime().second());while (!m_stop){m_Mutex.lock();m_diceValue = qrand() % 6 + 1;m_seq++;m_Mutex.unlock();waitCondition.wakeOne();sleep(1);}quit();
}ConsumerThread::ConsumerThread()
{}void ConsumerThread::stopThread()
{m_stop = true;waitCondition.wakeOne(); // 需要给wait置信号，否则阻塞无法结束
}void ConsumerThread::run()
{m_stop = false;while (!m_stop){m_Mutex.lock();waitCondition.wait(&m_Mutex);emit newValued(m_seq, m_diceValue);m_Mutex.unlock();msleep(100);}quit();
}

在这里插入图片描述

五、信号量

QSemaphore信号量通常用于保护一定数量的相同的资源。QSemaphore是实现信号量功能的类，提供了以下函数：
  • acquire(int n)：尝试获得n个资源，如果不够将阻塞线程，直到n个资源可用
  • release(int n)：释放资源，如果资源已经全部可用，则可扩充资源总数
  • int available()：返回房前信号量的资源个数
  • bool tryAcquire(int n=1)：尝试获取n个资源，不成功是，不阻塞线程

1、实现程序

在这里插入图片描述

（1）创建项目，基于QDIalog

在这里插入图片描述

（2）创建线程类

（3）使用信号量实现功能

#include "threadtest.h"
#include <QSemaphore>const int bufferSize = 8;
int buffer1[bufferSize] = {0};
int buffer2[bufferSize] = {0};
int curBuf = 1; // 当前采集数据使用的缓冲区QSemaphore semEmptyBufs(2); // 两个资源
QSemaphore semFullBufs;ThreadDAQ::ThreadDAQ()
{}void ThreadDAQ::stopThread()
{m_stop = true;
}void ThreadDAQ::run()
{m_stop = false;int counter = 0;while(!m_stop){semEmptyBufs.acquire();for (int i = 0; i < bufferSize; ++i){if(curBuf == 1){buffer1[i] = counter;}else{buffer2[i] = counter;}counter++;msleep(50);}if(curBuf == 1){curBuf = 2;}else{curBuf = 1;}semFullBufs.release();}exit();
}ThreadShow::ThreadShow()
{}void ThreadShow::stopThread()
{m_stop = true;
}void ThreadShow::run()
{m_stop = false;int seq = 0;while(!m_stop){semFullBufs.acquire();int buf[bufferSize] = {0};if(curBuf == 1){memcpy(buf, buffer2, sizeof(int)*bufferSize);}else{memcpy(buf, buffer1, sizeof(int)*bufferSize);}emit newValue(buf, bufferSize, seq++);semEmptyBufs.release();}exit();
}
#include "dialog.h"
#include "ui_dialog.h"Dialog::Dialog(QWidget *parent) :QDialog(parent),ui(new Ui::Dialog)
{ui->setupUi(this);ui->btnStopThread->setEnabled(false);connect(&threadConsumer, SIGNAL(newValue(int*, int, int)),this, SLOT(on_threadNewValue(int*, int, int)));connect(&threadProducer, SIGNAL(started()),this, SLOT(on_threadProducer_started()));connect(&threadProducer, SIGNAL(finished()),this, SLOT(on_threadProducer_finished()));connect(&threadConsumer, SIGNAL(started()),this, SLOT(on_threadConsumer_started()));connect(&threadConsumer, SIGNAL(finished()),this, SLOT(on_threadConsumer_finished()));
}Dialog::~Dialog()
{delete ui;
}void Dialog::on_threadNewValue(int *data, int count, int seq)
{QString str = QString::asprintf("第%03d次,内容:", seq);for (int var = 0; var < count; ++var){str += QString::asprintf("%03d ,", data[var]);}ui->plainTextEdit->appendPlainText(str);
}void Dialog::on_btnStartThread_clicked()
{threadConsumer.start();threadProducer.start();ui->btnStartThread->setEnabled(false);ui->btnStopThread->setEnabled(true);
}void Dialog::on_btnStopThread_clicked()
{threadProducer.stopThread();threadConsumer.stopThread();ui->btnStartThread->setEnabled(true);ui->btnStopThread->setEnabled(false);
}void Dialog::on_btnClearText_clicked()
{ui->plainTextEdit->clear();
}void Dialog::on_threadProducer_started()
{ui->labelProducer->setText("Producer线程：started");
}void Dialog::on_threadProducer_finished()
{ui->labelProducer->setText("Producer线程：finished");
}void Dialog::on_threadConsumer_started()
{ui->labelConsumer->setText("Consumer线程：started");
}void Dialog::on_threadConsumer_finished()
{ui->labelConsumer->setText("Consumer线程：finished");
}

在这里插入图片描述

http://www.mmbaike.com/news/110254.html

相关文章：

  • 互联网架构关键词自动优化
  • 建网站一般用什么工具信息流优化师发展前景
  • 申请域网站做游戏推广怎么找客户
  • 摄影网站设计推销广告
  • 公司网站后台怎么上传视频百度爱采购推广一个月多少钱
  • 网站备案 流程百度竞价培训
  • 山西运城给网站做系统的公司seo搜外
  • 服务器搭建网站打不开成人馆店精准引流怎么推广
  • 武汉小程序网站开发谷歌商店下载官网
  • 网站模板50元网络营销方案策划
  • 做搜狗手机网站长尾网络营销电子版教材
  • 外贸网站优化seo网站外链平台
  • 这样做的网站百度一下打开网页
  • 上海seo网站建设所有代刷平台推广
  • 网站建设目标是什么指数是指什么
  • wordpress301跳转说说seo论坛
  • 网站建设实验报告总结沈阳seo收费
  • 网站开发常用字体第一推广网
  • 北京备案网站负责人长沙百度快速优化排名
  • cms企业网站源码视频推广平台
  • 网站代码免费下载百度搜索网址
  • WordPress挂文件下载百度seo什么意思
  • 网站销售怎么做的扬州seo推广
  • 免费网站服务自主建站
  • 做英文网站要请什么样的人做舆情分析系统
  • 网站开发课设个人总结优秀的网页设计案例
  • 响应式网站标准尺寸百度网址安全检测中心
  • 沈阳模板建站安徽seo顾问服务
  • 贵州企业品牌网站建设网店代运营诈骗
  • 电商网站设计文档北京网站优化策略