class Worker(QObject): mySignal = pyqtSignal() def __init__(self): super().__init__() def run(self): self.mySignal.emit() class MyRunnable(QRunnable): def __init__(self, func,*param): super().__init__() self.func = func self.param = param def run(self): self.func(self.param[0][0],self.param[0][1]) class test(QWidget): def __init__(self): super().__init__() self.name = 'name' self.setWindowTitle('测试') self.initUI() def initUI(self): self.label = QLabel(self) thread = QThread() worker = Worker() worker.moveToThread(thread) worker1 = Worker() worker1.moveToThread(thread) worker2 = Worker() worker2.moveToThread(thread) threadPool = QThreadPool() task1 = MyRunnable(self.func1, (1, 2)) task2 = MyRunnable(self.func2, (2, 2)) task3 = MyRunnable(self.func3, (3, 2)) #thread.started.connect(task1) worker.mySignal.connect(task1) worker1.mySignal.connect(task2) worker2.mySignal.connect(task3) threadPool.start(worker) threadPool.start(worker1) threadPool.start(worker2) threadPool.waitForDone() def func1(self,x,y): print(x+y) def func4(): self.label.setText(str(x+y)) func4() time.sleep(1) def func2(self, x,y): print(x + y) self.label.setText(str(x + y)) time.sleep(1) def func3(self, x,y): print(x + y) self.label.setText(str(x + y)) time.sleep(1) app = QApplication(sys.argv) main = test() main.show() sys.exit(app.exec_())报警:worker.mySignal.connect(task1) TypeError: argument 1 has unexpected type 'MyRunnable'怎么解决?
时间: 2024-01-14 11:02:04 浏览: 27
在这段代码中,`worker.mySignal` 是一个信号,它发出的信号将会触发 `task1` 的运行。但是你在连接信号和槽时,使用了错误的语法。正确的语法是将信号连接到槽,而你却在将信号连接到了 `MyRunnable` 对象。为了解决这个问题,你需要将 `worker.mySignal` 连接到 `task1.run` 方法。修改代码如下:
```
worker.mySignal.connect(task1.run)
worker1.mySignal.connect(task2.run)
worker2.mySignal.connect(task3.run)
```
这样就可以将信号和槽正确地连接起来了。
相关问题
import threading import queue import numpy as np import pandas as pd import sqlite3 class Task: def __init__(self, task_id, task_type, data): self.task_id = task_id self.task_type = task_type self.data = data def run(self): if self.task_type == 'analysis': result = self.analysis() elif self.task_type == 'calculation': result = self.calculation() else: raise ValueError('Invalid task type') return result def analysis(self): # data analysis return ... def calculation(self): # data calculation return ... class ThreadPool: def __init__(self, max_workers): self.max_workers = max_workers self.tasks = queue.Queue() self.results = {} def submit(self, task): self.tasks.put(task) def start(self): workers = [threading.Thread(target=self.worker) for _ in range(self.max_workers)] for worker in workers: worker.start() for worker in workers: worker.join() def worker(self): while True: try: task = self.tasks.get(block=False) except queue.Empty: break result = task.run() self.results[task.task_id] = result def get_result(self, task_id): return self.results.get(task_id, None)解析
这段代码实现了一个线程池,包含了两个类:Task 和 ThreadPool。
Task 类表示一个任务,包含了任务的 ID、类型和数据。其中,类型有两种,分别为 'analysis' 和 'calculation'。Task 类有一个 run 方法,用来执行任务,根据不同的类型调用不同的方法进行数据分析或计算,并返回结果。
ThreadPool 类表示一个线程池,包含了最大工作线程数、任务队列和结果字典。其中,任务队列用来存储待执行的任务,结果字典用来存储已执行任务的结果。ThreadPool 类有三个方法:
- submit 方法用来提交任务,将待执行的任务放入任务队列中。
- start 方法用来启动线程池,创建最大工作线程数个线程,并将它们启动,然后等待所有线程执行完毕。
- worker 方法是一个工作线程,它从任务队列中获取任务并执行,将执行结果存入结果字典中。
最后,ThreadPool 类还提供了一个 get_result 方法,用来获取指定任务的执行结果。如果该任务还未执行或已执行但没有返回结果,则返回 None。
这个线程建的有问题吗 class Worker(QtCore.QThread): sinOut = pyqtSignal(object) def __init__(self, parent=None): super(Worker, self).__init__(parent) # 设置工作状态与初始num数值 self.working = True self.num = 0 #def __del__(self): # 线程状态改变与线程终止 #self.working = False #self.wait() def stop(self): #线程状态改变与线程终止 self.working = False self.wait() def run(self): self.working = True while self.working == True: #file_str = 'File index{0}'.format(self.num) self.num += 1 # 发射信号 #self.sinOut.emit(file_str) self.sinOut.emit('1') # 线程休眠2秒 self.sleep(5)
这个线程看起来没有明显的问题,但是需要注意以下几点:
1. `sinOut` 信号的参数类型是 `object`,这样会使得信号的参数类型不明确,建议根据实际情况设置参数类型。
2. 在 `stop()` 方法中,需要等待线程结束后再返回,因此应该调用 `self.wait()` 方法。
3. 在 `run()` 方法中,应该将 `self.working = True` 放在 `while` 循环的外面,否则当 `working` 的值为 `False` 时,线程不会结束。
4. 在 `run()` 方法中,可以考虑使用 `QThread.msleep()` 方法代替 `time.sleep()` 方法,因为前者是线程安全的。
5. 在 `run()` 方法中,可以考虑增加一个条件判断,当 `working` 的值为 `False` 时,跳出循环以结束线程。
最终代码如下:
```
class Worker(QtCore.QThread):
sinOut = pyqtSignal(str)
def __init__(self, parent=None):
super(Worker, self).__init__(parent)
self.working = True
self.num = 0
def stop(self):
self.working = False
self.wait()
def run(self):
while self.working:
self.num += 1
self.sinOut.emit('1')
self.msleep(5000)
if not self.working:
break
```