3

在过去的几天里，我一直在尝试使用 QThreads 而不继承 QThread 的新的首选方法。我遇到的麻烦是当我尝试关闭我创建的一组线程时。我经常收到“在线程仍在运行时被破坏”消息（如果我在调试模式下运行，我还会收到一个分段错误对话框）。我的代码非常简单，我尝试按照我在互联网上找到的示例进行操作。

我的基本设置如下：我有一个简单的类，我想在单独的线程中运行；事实上，我想运行这个类的 5 个实例，每个实例都在一个单独的线程中。我有一个简单的对话框，其中包含一个启动每个线程的按钮和一个停止每个线程的按钮（10 个按钮）。当我单击其中一个“开始”按钮时，会创建一个新的测试类实例，创建一个新的 QThread，调用 movetothread 以将测试类对象传递给线程......另外，因为我有几个在测试类中需要移动到线程的其他成员中，我使用这些其他项目额外调用了几次 movetothread。请注意，其中一项是 QUdpSocket，虽然这可能没有意义，但我想确保可以以这种方式将套接字移动到单独的线程......我没有

线程的启动似乎一切正常。当我使用 linux top 命令查看线程是否已创建并运行时，它们会按预期显示。

当我开始停止线程时会出现问题。我随机（或看起来是随机的）得到上述错误。

在单独线程中运行的类：

// Declaration
class TestClass : public QObject
{
Q_OBJECT
public:
explicit TestClass(QObject *parent = 0);
QTimer m_workTimer;
QUdpSocket m_socket;

Q_SIGNALS:
void finished();

public Q_SLOTS:
void start();
void stop();
void doWork();

};

// Implementation
TestClass::TestClass(QObject *parent) :
QObject(parent)
{

}

void TestClass::start()
{
  connect(&m_workTimer, SIGNAL(timeout()),this,SLOT(doWork()));
  m_workTimer.start(50);
}

void TestClass::stop()
{
  m_workTimer.stop();
  emit finished();
}

void TestClass::doWork()
{
int j;
for(int i = 0; i<10000; i++)
  {
    j = i;
  }
}

在我的主应用程序中，调用了启动第一个线程的代码（其他每个线程都存在类似的代码）：

mp_thread1 = new QThread();
mp_testClass1 = new TestClass();
mp_testClass1->moveToThread(mp_thread1);
mp_testClass1->m_socket.moveToThread(mp_thread1);
mp_testClass1->m_workTimer.moveToThread(mp_thread1);

connect(mp_thread1, SIGNAL(started()), mp_testClass1, SLOT(start()));
connect(mp_testClass1, SIGNAL(finished()), mp_thread1, SLOT(quit()));
connect(mp_testClass1, SIGNAL(finished()), mp_testClass1, SLOT(deleteLater()));
connect(mp_testClass1, SIGNAL(finished()), mp_thread1, SLOT(deleteLater()));
connect(this,SIGNAL(stop1()),mp_testClass1,SLOT(stop()));

mp_thread1->start();

同样在我的主应用程序中，当为特定线程（在本例中为线程 1）单击停止按钮时，将调用此代码：

emit stop1();

有时似乎线程被停止和销毁而没有问题。其他时候，我收到上述错误。

任何指导将不胜感激。

谢谢，

布莱恩

4

1 回答 1

4

http://mayaposch.wordpress.com/2011/11/01/how-to-really-truly-use-qthreads-the-full-explanation/

“最后，为了防止由于线程在被删除时还没有完全关闭而导致严重的崩溃，我们将线程的finished()（不是worker！）连接到它自己的deleteLater()槽。这将导致线程只有在完全关闭后才能删除。”

请尝试更换：

    connect(mp_testClass1, SIGNAL(finished()), mp_thread1, SLOT(deleteLater()));

和：

    connect(mp_thread1, SIGNAL(finished()), mp_thread1, SLOT(deleteLater()));
于 2012-10-16T07:15:22.007 回答