了解 qthread 子类的 run 方法和线程上下文

Question

我有一个带有很多方法的编码器类。这是 Qthread 的子类。我是多线程新手

试图理解这个类是怎样的 线程化其方法

...我理解线程化它必须位于 qthread 子类中的方法。并且它的运行实现了该类的线程代码。仅当调用此类对象的 start 方法时，线程才会启动。

问题：首先你推断出什么 从这次运行实现

void Encoder::run(void)
{
    VERBOSE(VB_DEBUG, "Encoder::run");

    if (WILL_PRINT(VB_DEBUG))
        print_stats_timer_id = QObject::startTimer(kEncoderDebugInterval);
    health_check_timer_id = QObject::startTimer(kEncoderHealthCheckInterval);

    if (init())
        exec();
    else
        VERBOSE(VB_ERROR, "Encoder::run -- failed to initialize encoder");

    QObject::killTimer(health_check_timer_id);
    if (print_stats_timer_id)
        QObject::killTimer(print_stats_timer_id);

    cleanup();
}

问题：线程上下文的含义是什么 与其方法有关。

还

问题：如果使用此方法会发生什么 类在该类之前被调用 线程已启动

Answer 1

1. 您编写的类创建一个线程并初始化一个 QObject::timer。然后它继续调用用户定义的 init() 函数，然后调用 QThread::exec () 函数。

   1. 我的猜测是，您希望 exec() 是一个用户定义的函数，实际工作将在其中发生。请注意，QThread::exec() 处理线程的 Qt 事件队列。
   2. 此外，在某些平台上，您可能会收到“从线程创建计时器时出错”警告消息。我在 Windows 上遇到了这个错误，而代码在 Linux 上执行得很好
   3. 此外，请注意，如果您不调用 QThread::exec() 函数或 QApplication::processEvents() 来自您的线程。

2. Qt 中的线程上下文与任何其他线程概念相同。也就是说，所有内存都在线程代码之间共享（此时在“run()”函数中输入）。以及调用您的对象的任何其他上下文。如果此对象可能在线程中执行并从线程外部访问，则您必须保护共享数据。

3. 因为所有数据在线程上下文之间共享（它是共享内存多处理模型），所以在线程执行之前/之后/期间调用函数没有问题。鉴于：
   1. 在调用任何方法之前，对象已完全构造完毕。这对于线程来说并不特殊，除非该对象是在线程中创建的。
   2. 任何数据成员都受到互斥锁的保护（我在#2 中回避了这一点）。 QMutexLocker 是一种方便的基于堆栈的 RAII 方法，用于处理 Qt 中的互斥锁。< /里>

我相信我在这里完全回答了您的问题，所以我将继续链接到 RAII 和 < a href="http://blog.emptycrate.com/taxonomy/term/38" rel="nofollow">线程 我在另一个网站上写的文章，仅供进一步参考。

编辑：有关线程场景的特殊性：

class MyThreadedClass : public QThread
{
  MyThreadClass(const boost::shared_ptr<SomeOtherClass> &t_object)
    : m_object(t_object) {}

  void doSomething()
  {
    // Depending on how this method was called (from main, from internal thread)
    // will determine which thread this runs on, potentially complicating thread
    // safety issues.
    m_object->someThing(); 
  }

  void run()
  {
    // I'm now in a thread!
    m_object->someFunction(); // oops! The call to someFunction is occurring from 
                              // a thread, this means that SomeOtherClass must be 
                              // threadsafe with mutex guards around shared 
                              // (object level) data.
    // do some other stuff
  }
};

int main()
{
  MyThreadClass thread(someobjectfromsomewhere);
  thread.start(); // MyThreadClass is now running
  thread.doSomething(); // The call to doSomething occurs from main's thread.
                        // This means 2 threads are using "thread", main 
                        // and "thread"'s thread. 
  // The call to thread.doSomething hits Thread.m_object, which means that 
  // now multiple threads are also accessing m_object ("thread" and "main").
  // This can all get very messy very quickly. It's best to tightly control 
  // how many threads are hitting an object, and how
}

• 注意：调查 QFuture 是个好主意，它旨在处理这种异步任务，就像编码器一样，您正在查看 QFuture 将避免共享数据和死锁的一些潜在线程问题。