日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

Qt采用線程以隊列方式實現下發數據_C 語言

作者：中國好公民st ? 更新時間： 2022-11-23 編程語言

什么叫做隊列方式

在C++中隊列是一種常用的數據結構之一，一種特殊的線性表，一般采用先進先出的方式。

很多情況下，在做數據處理時，會根據先來后到的原則進行處理。對于少量數據來說，主進程就可以很快完成，所以不需要用到開線程的方式。將處理處理部分封裝成一個函數，直接調用就OK了！

假設，數據處理的時間消耗很大時，繼續使用主進程處理的話，肯定會導致頁面卡死，為了避免頁面卡死，最常用的方式就是開線程。

在程序使用過程中肯定不止一個位置進行數據處理，那么，多次調用數據處理時，如何保證按照觸發順序進行數據解析呢？

這是本篇文章中的重點~

想要按照觸發順序下發，必須要對下發的數據進行排隊，這里用到的容器是list。方便添加、刪除。

容器：std::list m_list; //存儲數據

1.存儲需要處理的數據

std::lock_guard<std::mutex> lck(m_mutexRobotData); //上鎖添加數據
m_list.push_back(stData);

在進行數據存儲時，進行上鎖處理，因為在線程中每處理一條數據，需要進行刪除，防止出錯。

2.開啟線程

m_pThreadSendCmd = std::thread(&QWidget::ProcessingThread, this);
m_pThreadSendCmd.detach();

這里用到的是C11方式開啟線程，有一個弊端，使用功能detach方式后，已經與程序脫離了，想要控制線程的關閉，保守的做法是由參數來控制。

這里，我才用了bool值，當bool = false時，說明線程停止；true表示線程正在運行。

那么，對上述開啟線程方式進行修改，如下：

if (m_bRunningRobotCmd == false)
{
	//線程未開啟，開啟線程
	qDebug() << QStringLiteral("開啟一個新線程");
	m_bRunningRobotCmd = true;
	m_pThreadSendCmd = std::thread(&QWidget::ProcessingThread, this);
	m_pThreadSendCmd.detach();
}

3.線程中數據處理

void QWidget::ProcessingThread()
{
    while(m_bRunningRobotCmd)
    {
        //線程處理
        sleep(200);
    }
    //退出while循環，表示線程結束
}

此時，當m_bRunningRobotCmd = true時，表示線程一直在啟動，當m_bRunningRobotCmd = false時，立刻停止線程，這時又會遇到一個問題，正在運行的線程中該如何停止呢？

單純的m_bRunningRobotCmd = false，很顯然停止的概率不大，此時，對安全的做法，需要用互斥量的方式，進行停止

對上述線程開啟進行修改，如下：

void QWidget::ProcessingThread()
{
    std::lock_guard<std::mutex> lck(m_mutexControlThread); //上鎖添加數據
    while(m_bRunningRobotCmd)
    {
        //線程處理
        sleep(200);
    }
    //退出while循環，表示線程結束
}

關閉線程方式，如下：

m_bRunningRobotCmd = false;
std::lock_guard<std::mutex> lck(m_mutexControlThread);  //插入數據之前，首先加鎖

首先將bool值更改，再進行加鎖。

4.線程內容實現邏輯

當list容器中存在數據時，需要獲取第一條數據，處理后刪除第一條數據。

實現代碼如下：

if(m_list.size() != 0)
{
    //容器中存在有效數據
    std::lock_guard<std::mutex> lck(m_mutexRobotData); //上鎖添加數據
    if(m_list.size() != 0)
    {
        //獲取第一條有效數據
        stData stInfo = m_list.front();
        //數據處理
        //刪除第一條數據
        m_list.pop_front();
    }
    
}

使用互斥量的方式控制線程增加了安全性，防止崩潰問題。

原文鏈接：https://juejin.cn/post/7153420828959309855

欄目分類
最近更新