Pyside2的线程使用

RT，查了Qt关于Pyside2的相关资料，对QThread的介绍使用还是override了run方法，并没有Qt目前主推的moveToThread方法，我按照自己的理解使用Python写了多线程。但是打印结果不正确，有谁能给找下问题，介绍下么？
MultiThreadTest：创建线程，信号槽触发。
Worker：被移入新线程的类
具体代码如下
Worker：

1. #!/usr/bin/env python
   
2. # encoding: utf-8
   
3. # @author: qiaowei
   
4. # @license: (C) Copyright 2013-2019
   
5. # @contact: weiweiqiao@126.com
   
6. # @file: worker.py
   
7. # @time: 2020/7/28 0028
   
8. # @desc:
   
9. 
   
10. 
    
11. import threading
    
12. from PySide2.QtCore import QThread
    
13. from PySide2.QtCore import Slot
    
14. from PySide2.QtCore import QObject
    
15. 
    
16. 
    
17. class Worker(QObject):
    
18.     def __init__(self):
    
19.         super().__init__()
    
20.         # print('Worker.__init__ = ' + str(id(QThread.currentThread())))
    
21. 
    
22.     @Slot()
    
23.     def do_something(self):
    
24.         # print('Worker.do_something = ' + str(threading.currentThread()))
    
25.         print('Worker.do_something = ' + str(QThread.currentThread()))
    

复制代码

MultiThreadTest：

1. #!/usr/bin/env python
   
2. # encoding: utf-8
   
3. # @author: qiaowei
   
4. # @license: (C) Copyright 2013-2019
   
5. # @contact: weiweiqiao@126.com
   
6. # @file: multithread_test.py
   
7. # @time: 2020/7/28 0028
   
8. # @desc:
   
9. 
   
10. import threading
    
11. from PySide2.QtCore import QThread
    
12. from PySide2.QtCore import QObject
    
13. from PySide2.QtCore import Signal
    
14. 
    
15. from multithread.worker import Worker
    
16. 
    
17. 
    
18. class MultiThreadTest(QObject):
    
19.     def __init__(self):
    
20.         super().__init__()
    
21.         self.__thread_a = QThread()
    
22.         self.__worker = Worker()
    
23.         self.send_msg.connect(self.__worker.do_something)
    
24.         # pass
    
25. 
    
26.     def start_multithread(self):
    
27.         # print('MultithreadTest.start_multithread = ' + str(threading.currentThread()))
    
28.         print('MultithreadTest.start_multithread = ' + str(QThread.currentThread()))
    
29.         multi_thread = MultiThreadTest()
    
30. 
    
31.         self.__worker.moveToThread(self.__thread_a.thread())
    
32.         self.__thread_a.start()
    
33.         # self.__thread_a.sleep(3)
    
34.         # print('MultithreadTest.start_multithread = ' + str(threading.currentThread()))
    
35.         print('MultithreadTest.start_multithread = ' + str(QThread.currentThread()))
    
36.         # multi_thread.send_msg.emit()
    
37.         self.send_msg.emit()
    
38.         # print('MultithreadTest.start_multithread = ' + str(threading.currentThread()))
    
39.         print('MultithreadTest.start_multithread = ' + str(QThread.currentThread()))
    
40. 
    
41.     # 定义无参数信号槽
    
42.     send_msg = Signal()
    

复制代码

运行：

1. #!/usr/bin/env python
   
2. # encoding: utf-8
   
3. # @author: qiaowei
   
4. # @license: (C) Copyright 2013-2019
   
5. # @contact: weiweiqiao@126.com
   
6. # @file: start_test.py
   
7. # @time: 2020/7/28 0028
   
8. # @desc:
   
9. 
   
10. 
    
11. from multithread.multithread_test import MultiThreadTest
    
12. 
    
13. 
    
14. start_01 = MultiThreadTest()
    
15. start_01.start_multithread()
    

复制代码

运行结果

1. MultithreadTest.start_multithread = <PySide2.QtCore.QThread object at 0x0000000002FE6408>
   
2. MultithreadTest.start_multithread = <PySide2.QtCore.QThread object at 0x0000000002FE62C8>
   
3. Worker.do_something = <PySide2.QtCore.QThread object at 0x0000000002FE62C8>
   
4. MultithreadTest.start_multithread = <PySide2.QtCore.QThread object at 0x0000000002FE62C8>

复制代码

mark，有空研究一下。

有知道的coder能给解释下么？