QTcpSocket経由のデータストリームから複雑なアルゴリズムを連続して実行するための最適なQTスレッディングソリューションは何ですか？

Question

私は現在の仕事で複雑なプログラムを継承しており、QTcpSocketを経由してくるデータの流れからイメージのちらつきを減らそうとしています。

プログラムは連続したデータストリームを受け取り、それを処理してからpaintEventで画面にペイントします。

処理機能は、信号がQTcpSocketからのreadyread（）であり、スロットがデータ処理機能である信号/スロット接続に基づいて実行されます。ストリームは連続的なので、この信号/スロットは着信データに基づいてスクリーン上のペイントされた画像を連続的に発射し更新する。

イメージが瞬時にちらつき、メインイベントループの処理がデータストリームに干渉している可能性があるので、私の考えはデータ処理機能を独自のスレッドに入れることでした。このデータ処理関数は、プログラムの他の機能に完全に統合されているため、この時点でデータストリームをサブクラス化して、QThreadを適用することはできません。また、プログラム全体の完全なリストアになります。 。

だから、私の考えはそうのようなQtConcurrentを使用していた：

connect(tcpSocket2, SIGNAL(readyRead()), this, SLOT(getData())); 

だから私は（SLOTを置き換え：のgetData（）はreadyread（）信号に接続されたデータ処理機能である

void MainWindow::getDataThread(){  //implemented as a slot 
    wpFuture = QtConcurrent::run(this, &MainWindow::getData); 
} 

getData（））とSLOT（getDataThread（））を使用して、グローバルスレッドプールから取得された新しいスレッドでデータ処理関数を実行できるようにします。ストリームは連続しているので、getData処理関数が実行されるたびに常に新しいスレッドが割り当てられていると思います。ちらつきを減らすように見えますが、約30〜60秒後にプログラムはランダムにクラッシュし、特定の吹き出しは発生しません。

私の質問は：データストリームをサブクラス化せずに、自分のデータ処理機能をスレッドするためのより良い方法はありますか？この特定の状況でQtConcurrentを実装する際に私の思考や理解が間違っていますか？

ありがとうございます。

Answer 1

あなたのご意見からは、スレッドプールの理解が間違っていると思います。

スレッドプールには多数のスレッドがあります。 QtConcurrent::runを呼び出すたびに、グローバルスレッドプールから空きスレッドが取得され、実行するタスクが渡されます（MainWindow::getData）。 MainWindow::getDataが（おそらく）異なるスレッドで実行されるたびにQtConcurrent::runを何度も呼び出すと、スレッドプールに現在使用可能なスレッドがない場合、タスクはキューに入れられ、後で利用可能になるとスレッドに渡されます。この方法では、スレッドプール内のスレッドの数によって制限された複数の同時実行タスクを実行できます。

今や問題は、MainWindow::getDataはおそらくその設計上スレッドセーフではないということです。数回呼び出されたQtConcurrent::run(this, &MainWindow::getData);は、データ競合につながる可能性があります。

あなたはデータを処理するために別個の単一スレッドはその後、ちょうど（何でも「サブクラス」する必要はありません）QThreadを使用する場合：contextオブジェクトが生きているとthreadが毎回QTcpSocket::readyReadを実行している

今

// A thread and its context are created only once 
QThread thread; 
QObject context; 
context.moveToThread(&thread); 
// ... 

QObject::connect(tcpSocket2, &QTcpSocket::readyRead, &context, [this]() { 
    this->getData(); 
}, Qt::QueuedConnection); 

thread.start() 

限りemmited - ラムダが実行されます。

ワーカースレッドとメインスレッドが、getDataに衝突しないように注意してください。