什么叫做隊列方式

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

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

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

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

這是本篇文章中的重點~

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

容器：std::list m_list; //存儲數(shù)據(jù)

1.存儲需要處理的數(shù)據(jù)

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

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

2.開啟線程

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

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

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

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

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

3.線程中數(shù)據(jù)處理

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

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

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

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

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

關閉線程方式，如下：

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

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

4.線程內(nèi)容實現(xiàn)邏輯

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

實現(xiàn)代碼如下：

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

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

到此這篇關于Qt采用線程以隊列方式實現(xiàn)下發(fā)數(shù)據(jù)的文章就介紹到這了,更多相關Qt隊列方式下發(fā)數(shù)據(jù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

最新評論