2. 程式人生 > >Qt---多執行緒應用的例子

Qt---多執行緒應用的例子

阿新 • • 發佈：2019-02-19

這裡寫圖片描述

伺服器端

這裡寫圖片描述

TimeThread建立TcpSocket，負責實現Run()函式，傳送伺服器端資訊，然後斷開連線。
TimeSever中建立TimeThread，實incomingConnection(int socketDescriptor)函式每當有新的客戶端連線時，建立新的執行緒，將執行緒結束函式與對話方塊中的退出按鈕繫結，然後啟動執行緒
Dialog中建立TimeSever，對客戶端監聽

.pro中新增：

QT       += network

timethread.h

#ifndef TIMETHREAD_H
#define TIMETHREAD_H

#include <QThread>
 

#include <QtNetwork>
#include <QTcpSocket>

class TimeThread : public QThread
{
    Q_OBJECT

public:
    TimeThread(int socketDescriptor,QObject *parent=0);
    void run();

signals:
    void error(QTcpSocket::SocketError socketError);

private:
    int socketDescriptor;
};

#endif // TIMETHREAD_H

timethread.cpp

#include "timethread.h"
#include <QDateTime>
#include <QByteArray>
#include <QDataStream>

TimeThread::TimeThread(int socketDescriptor, QObject *parent)
    :QThread(parent), socketDescriptor(socketDescriptor)
{
}

void TimeThread::run()
{
    QTcpSocket tcpSocket;
 

    if(!tcpSocket.setSocketDescriptor(socketDescriptor))
    {
        emit error(tcpSocket.error());
        return;
    }
    QByteArray block;
    QDataStream out(&block, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_3);

    uint time2u = QDateTime::currentDateTime().toTime_t();
    out << time2u;

    tcpSocket.write(block);
    tcpSocket.disconnectFromHost();
    tcpSocket.waitForDisconnected();
}

timeserver.h

#ifndef TIMESERVER_H
#define TIMESERVER_H

#include <QTcpServer>

class Dialog;  //伺服器端的宣告

class TimeServer:public QTcpServer
{
    Q_OBJECT

public:
    TimeServer(QObject *parent = 0);

protected:
    void incomingConnection(int socketDescriptor);

private:
    Dialog *dlg;
};

#endif // TIMESERVER_H

timeserver.cpp

#include "timeserver.h"
#include "timethread.h"
#include "dialog.h"

TimeServer::TimeServer(QObject *parent): QTcpServer(parent)
{
    dlg = (Dialog *)parent;
}

void TimeServer::incomingConnection(int socketDescriptor)
{
    TimeThread *thread = new TimeThread(socketDescriptor, 0);

    connect(thread, SIGNAL(finished()), dlg, SLOT(slotShow()));
    connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()), Qt::DirectConnection);

    thread->start();
}

dialog.h

#ifndef DIALOG_H
#define DIALOG_H

#include <QDialog>
#include <QLabel>
#include <QPushButton>

class TimeServer;

class Dialog:public QDialog
{
    Q_OBJECT

public:
    Dialog(QWidget *parent = 0);
    ~Dialog();

public slots:
    void slotShow();

private:
    QLabel *Label1;
    QLabel *Label2;
    QPushButton *quitBtn;
    TimeServer *timeServer;
    int count;
};

#endif // DIALOG_H

dialog.cpp

#include "dialog.h"
#include <QHBoxLayout>
#include <QVBoxLayout>
#include <QMessageBox>
#include "timeserver.h"

Dialog::Dialog(QWidget *parent): QDialog(parent)
{
    setWindowTitle(tr("多執行緒時間伺服器"));

    Label1 =new QLabel(tr("伺服器埠："));
    Label2 = new QLabel;

    quitBtn = new QPushButton(tr("退出"));
    QHBoxLayout *BtnLayout = new QHBoxLayout;
    BtnLayout->addStretch(1);
    BtnLayout->addWidget(quitBtn);
    BtnLayout->addStretch(1);

    QVBoxLayout *mainLayout = new QVBoxLayout(this);
    mainLayout->addWidget(Label1);
    mainLayout->addWidget(Label2);
    mainLayout->addLayout(BtnLayout);

    connect(quitBtn, SIGNAL(clicked()), this, SLOT(close()));

    count=0;
    timeServer = new TimeServer(this);
    if(!timeServer->listen())
    {
        QMessageBox::critical(this,tr("多執行緒時間伺服器"),
        tr("無法啟動伺服器：%1.").arg(timeServer->errorString()));
        close();
        return;
    }
    Label1->setText(tr("伺服器埠：%1.").arg(timeServer->serverPort()));
}

Dialog::~Dialog()
{

}

void Dialog::slotShow()
{
    Label2->setText(tr("第%1次請求完畢。").arg(++count));
}

main.cpp

#include "dialog.h"
#include <QApplication>

/*
 *TimeThread建立TcpSocket，負責實現Run()函式，傳送伺服器端資訊，然後斷開連線
 *TimeSever中建立TimeThread，實現incomingConnection(int socketDescriptor)函式
 *每當有新的客戶端連線時，建立新的執行緒，將執行緒結束函式與對話方塊中的退出按鈕繫結，然後啟動執行緒
 *Dialog中建立TimeSever，對客戶端監聽
 */

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

客戶端

這裡寫圖片描述

初始化中建立socket，點選“獲取時間”按鈕後，socket連線伺服器，
當伺服器傳送來資料時，訊號函式readyRead()執行，觸readTime()函式獲取伺服器端時間。
在讀取資料時，採用QDataStream

.pro

QT       += network

timeclient.h

#ifndef TIMECLIENT_H
#define TIMECLIENT_H

#include <QDialog>
#include <QLabel>
#include <QLineEdit>
#include <QPushButton>
#include <QDateTimeEdit>
#include <QTcpSocket>
#include <QAbstractSocket>

class TimeClient : public QDialog
{
    Q_OBJECT

public:
    TimeClient(QWidget *parent = 0);
    ~TimeClient();
public slots:
    void enableGetBtn();
    void getTime();
    void readTime();
    void showError(QAbstractSocket::SocketError socketError);
private:
    QLabel *serverNameLabel;
    QLineEdit *serverNameLineEdit;
    QLabel *portLabel;
    QLineEdit *portLineEdit;
    QDateTimeEdit *dateTimeEdit;
    QLabel *stateLabel;

    QPushButton *getBtn;
    QPushButton *quitBtn;

    uint time2u;
    QTcpSocket *tcpSocket;
};

#endif // TIMECLIENT_H

timeclient.cpp

#include "timeclient.h"
#include <QHBoxLayout>
#include <QVBoxLayout>
#include <QGridLayout>
#include <QDataStream>
#include <QMessageBox>

TimeClient::TimeClient(QWidget *parent): QDialog(parent)
{
    setWindowTitle(tr("多執行緒時間服務客戶端"));

    serverNameLabel =new QLabel(tr("伺服器名："));
    serverNameLineEdit = new QLineEdit("Localhost");

    portLabel =new QLabel(tr("埠："));
    portLineEdit = new QLineEdit;

    QGridLayout *layout = new QGridLayout;
    layout->addWidget(serverNameLabel, 0, 0);
    layout->addWidget(serverNameLineEdit, 0, 1);
    layout->addWidget(portLabel, 1, 0);
    layout->addWidget(portLineEdit, 1, 1);

    dateTimeEdit = new QDateTimeEdit(this);
    QHBoxLayout *layout1 = new QHBoxLayout;
    layout1->addWidget(dateTimeEdit);

    stateLabel =new QLabel(tr("請首先執行時間伺服器！"));
    QHBoxLayout *layout2 = new QHBoxLayout;
    layout2->addWidget(stateLabel);

    getBtn = new QPushButton(tr("獲取時間"));
    getBtn->setDefault(true);
    getBtn->setEnabled(false);
    quitBtn = new QPushButton(tr("退出"));
    QHBoxLayout *layout3 = new QHBoxLayout;
    layout3->addStretch();
    layout3->addWidget(getBtn);
    layout3->addWidget(quitBtn);

    QVBoxLayout *mainLayout = new QVBoxLayout(this);
    mainLayout->addLayout(layout);
    mainLayout->addLayout(layout1);
    mainLayout->addLayout(layout2);
    mainLayout->addLayout(layout3);

    connect(serverNameLineEdit, SIGNAL(textChanged(QString)), this, SLOT(enableGetBtn()));
    connect(portLineEdit, SIGNAL(textChanged(QString)), this, SLOT(enableGetBtn()));
    connect(getBtn, SIGNAL(clicked()), this, SLOT(getTime()));
    connect(quitBtn, SIGNAL(clicked()), this, SLOT(close()));

    tcpSocket = new QTcpSocket(this);
    connect(tcpSocket, SIGNAL(readyRead()), this, SLOT(readTime()));
    connect(tcpSocket, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(showError(QAbstractSocket::SocketError)));

    portLineEdit->setFocus();
}

TimeClient::~TimeClient()
{

}

void TimeClient::enableGetBtn()
{
    getBtn->setEnabled(!serverNameLineEdit->text().isEmpty() && !portLineEdit->text().isEmpty());
}

void TimeClient::getTime()
{
    getBtn->setEnabled(false);
    time2u =0;
    tcpSocket->abort();  //取消已有連線
    tcpSocket->connectToHost(serverNameLineEdit->text(), portLineEdit->text().toInt());
}

void TimeClient::readTime()
{
    QDataStream in(tcpSocket);
    in.setVersion(QDataStream::Qt_4_3);
    if(time2u==0)
    {
        if(tcpSocket->bytesAvailable()<(int)sizeof(uint))
            return;
        in >> time2u;
    }
    dateTimeEdit->setDateTime(QDateTime::fromTime_t(time2u));
    getBtn->setEnabled(true);
}

void TimeClient::showError(QAbstractSocket::SocketError socketError)
{
    switch (socketError)
    {
    case QAbstractSocket::RemoteHostClosedError:
        break;
    case QAbstractSocket::HostNotFoundError:
         QMessageBox::information(this, tr("時間服務客戶端"), tr("主機不可達！"));
         break;
    case QAbstractSocket::ConnectionRefusedError:
         QMessageBox::information(this, tr("時間服務客戶端"), tr("連線被拒絕！"));
         break;
    default:
        QMessageBox::information(this, tr("時間服務客戶端"),tr("產生如下錯誤: %1.").arg(tcpSocket->errorString()));
    }
    getBtn->setEnabled(true);
}

main.cpp

#include "timeclient.h"
#include <QApplication>

/*
 * 初始化中建立socket，點選“獲取時間”按鈕後，socket連線伺服器，
 * 當伺服器傳送來資料時，訊號函式readyRead()執行，觸發readTime()函式獲取伺服器端時間
 * 在讀取資料時，採用QDataStream
 */
int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    TimeClient w;
    w.show();

    return a.exec();
}

相關推薦

Qt---多執行緒應用的例子

伺服器端 TimeThread建立TcpSocket，負責實現Run()函式，傳送伺服器端資訊，然後斷開連線。 TimeSever中建立TimeThread，實incomingConnection(int socketDescriptor)函式每當有

多執行緒應用例子2—消費者，生產者，多個緩衝區

將消費者改成2個，緩衝池改成擁有4個緩衝區的大緩衝池。 用二個訊號量就可以解決這種緩衝池有多個緩衝區的情況——用一個訊號量A來記錄為空的緩衝區個數，另一個訊號量B記錄非空的緩衝區個數，然後生產者等待訊號量A，消費者等待訊號量B就可以了。因此可以仿照上面的程式碼來實現複

Qt 多執行緒的一個例子

(1)用VC6.0新建個Win32 Console　Application工程(2)Project Settings裡面Link標籤頁面新增qtmain.lib qt-mt320.lib   Project Settings裡面C/C++標籤頁面新增QT_THREAD_SUP

Python多執行緒小例子

Python多執行緒小例子 1、在主執行緒中建立子執行緒 下面的程式碼一共建立了三個執行緒：主執行緒、coding 執行緒和music 執行緒，最後使用thread_list 裝載執行緒

QT多執行緒淘酒，持續更新

第一階段 首先必須區分三個概念: 主執行緒:在程式初始化完成後，主執行緒就進入了main()函式開始執行應用程式碼，一般在主執行緒上構建介面物件並呈現之，然後就進入了事件迴圈以處理各類訊息(控制元件繪製、使用者輸入、系統輸出等訊息)。這就是熟知的事件驅動模型。 工作執行緒:也就是子執

QT多執行緒中，物件訊號與槽連線不上的解決辦法

1、在接收者建立執行緒中，把接收者移動到主執行緒中： pReceiverObj->moveToThread(QApplication::instance()->thread()); 2、這樣傳送訊號的時候，就會在主執行緒事件佇列處理中來處理了。 把connect的最

QT學習記錄2（QT多執行緒）

對QT多執行緒的理解 qt多執行緒基於QThread類，在使用的時候，可以選擇新建類，然後繼承QThread類，然後重寫run函式，從而實現QT多執行緒   QT多執行緒小例程 首先，建立一個QT工程，名字叫做mythread，視窗選擇widget，然後一路下一步即可，生成

java多執行緒應用場景

                                       java多執行緒應用場

qt多執行緒之 std::thread

不時見到有人會這樣做： 不使用QThread，而是使用pthread等平臺相關的底層 api 而又不想使用底層執行緒間同步、通訊的api 那麼，如何使用pthread，而又使用Qt提供的執行緒間機制呢？ 本文的初衷源於此，但是使用的的是C++0x 的 std::threa

Qt 多執行緒伺服器與客戶端

文章目錄 思路 伺服器 myserver.h myserver.cpp mythread.h mythread.cpp mysocket.h mysocket.cpp

Qt多執行緒同步

       一、Qt中使用多執行緒時候，多執行緒的同步就是一個不可避免的問題。多執行緒的同步就是使多個執行緒在同時執行同一段程式碼的時候，有順序的執行,不會出現同時有兩個或者多個執行緒執行同一段程式碼的情況，特別是在對變數或者檔案執行寫操作的時候。也就是所謂的

Qt多執行緒-QThreadPool執行緒池與QRunnable

介紹 執行緒的建立及銷燬需要與系統互動，會產生很大的開銷。若需要頻繁的建立執行緒建議使用執行緒池，有執行緒池維護一定數量的執行緒，當需要進行多執行緒運算時將運算函式傳遞給執行緒池即可。執行緒池會根據可用執行緒進行任務安排。 QThreadPool 此類為Qt提供

12章多執行緒應用案例

龜兔賽跑：20米     //只要為了看到效果，所有距離縮短了  要求： 1.兔子每秒0.5米的速度，每跑2米休息10秒， 2.烏龜每秒跑0.1米，不休息    3.其中一個跑到終點後另一個不跑

QT 多執行緒程式設計

QT通過三種形式提供了對執行緒的支援。它們分別是，一、平臺無關的執行緒類，二、執行緒安全的事件投遞，三、跨執行緒的訊號-槽連線。這使得開發輕巧的多執行緒Qt程式更為容易，並能充分利用多處理器機器的優勢。多執行緒程式設計也是一個有用的模式，它用於解決執行較長時間的操作而不至於使用者介面失去響應。在Qt的早期

【Qt多執行緒之執行緒的等待和喚醒】QWaitCondition

QWatiCondition的成員函式 ·QWaitCondition() ·~QWaitCondition() ·bool wait ( QMutex * mutex, unsigned long time = ULONG_MAX ) ·vo

iOS經典講解之多執行緒應用場景

<pre name="code" class="objc"> 通過下面一個例子來了解一下多執行緒的應用場景，我們可以通過點選按鈕來開始或者暫停動畫的播放，但是當我們點選另一個按鈕時， 就會執行一個方法，在該方法中迴圈列印一個很大的數字，在列印過程中，再通過點

Qt多執行緒學習：建立多執行緒

【為什麼要用多執行緒？】 傳統的圖形使用者介面應用程式都只有一個執行執行緒，並且一次只執行一個操作。如果使用者從使用者介面中呼叫一個比較耗時的操作，當該操作正在執行時，使用者介面通常會凍結而不再響應。這個問題可以用事件處理和多執行緒來解決。 【Linux有執行緒的概念嗎？

python 多執行緒應用

#coding=utf-8 import threading from time import ctime,sleep def music(func): for i in range(2): print "I was listening to %s. %s" %(func,ctim

QT多執行緒臨界資源互斥

多執行緒是個老梗，一般都會遇到，同樣臨界資源的互斥訪問也是一個老生長談的問題了。這裡把最近使用的一種方法分享一下。 問題場景：主執行緒根據一定條件建立多個子執行緒，子執行緒執行的是同一個類不同例項的方法，該方法中需要向主執行緒傳送一個訊息顯示一個對話方塊用以接收使用者輸入；

C++11 std::unique_lock與std::lock_guard區別及多執行緒應用例項

C++多執行緒程式設計中通常會對共享的資料進行防寫，以防止多執行緒在對共享資料成員進行讀寫時造成資源爭搶導致程式出現未定義的行為。通常的做法是在修改共享資料成員的時候進行加鎖--mutex。在使用鎖的時候通常是在對共享資料進行修改之前進行lock操作，在寫完之後再進行unl