在我从键盘输入任何内容后，我想在 python 中运行多个线程，但我收到此错误 - 线程 Thread-4 中的异常：

Question

我想在 python 中运行多个线程，在我从键盘输入任何内容后出现此错误 - 线程 Thread-4 中的异常：

import threading
import os
import cv2

def task():
    user_input = input()
    print(user_input)
    print("Task assigned to thread: {}".format(threading.current_thread().name))
    print("ID of process running task : {}".format(os.getpid()))
    print("Thread started now")

if __name__ == "__main__":
    for i in range(1, 5):
         # Instantiates the thread
        t = threading.Thread(target=task, args=(i,))
        t.start()
        t.join()

Answer 1

您应该 post 整个回溯。这是我在所有 4 个线程中得到的：

Exception in thread Thread-1:
Traceback (most recent call last):
  File "C:\Python38\lib\threading.py", line 932, in _bootstrap_inner
    self.run()
  File "C:Python38\lib\threading.py", line 870, in run
    self._target(*self._args, **self._kwargs)
TypeError: task() takes 0 positional arguments but 1 was given

它说函数 task() 在不需要任何参数时被传递了参数，所以在创建线程时不要传递参数:

t = threading.Thread(target=task, args=())

或者让task()接受一个论点：

def task(i):

在线程中请求输入也没有任何意义。没有提示，您将不知道哪个线程正在接受输入。

由于使用 threading 而不是 multiprocessing 模块，os.getpid() 将在所有线程中 return 相同的值。

此外，如果您在同一个循环中启动和加入线程，则不会获得任何并行性。在一个循环中启动所有线程，然后在另一个循环中加入（等待完成）。

这是一个演示并行性的解决方案：

import threading
import os
import time

def task(i):
    print(f'Task#{i} started in {threading.current_thread().name}')
    time.sleep(5) # do some "work"
    print(f'Task#{i} done')

threads = [threading.Thread(target=task,args=(i,)) for i in range(1,5)]
print(f'Start: {time.ctime()}')
for t in threads:
    t.start()
for t in threads:
    t.join()
print(f'End:   {time.ctime()}')

输出（注意开始和结束时间相隔 5 秒）：

Start: Sat Feb 15 16:22:59 2020
Task#1 started in Thread-1
Task#2 started in Thread-2
Task#3 started in Thread-3
Task#4 started in Thread-4
Task#1 done
Task#2 done
Task#4 done
Task#3 done
End:   Sat Feb 15 16:23:04 2020

最后一点：由于 CPython 的全局解释器锁 (GIL) 实现，一个进程一次只能运行 Python 在一个线程中编码，因此threading 模块不会为 Python 密集型工作节省时间，但在 Python 等待 I/O 或调用释放 GIL 的本机 C 模块时很有用。 multiprocessing模块可用于创建多个Python进程，不受GIL限制，但进程初始化时间较长，参数通过进程间方法传递。

import multiprocessing as mp
import os
import time

def task(i):
    print(f'Task#{i} started in {mp.current_process().name}')
    time.sleep(5)
    print(f'Task#{i} done')

if __name__ == '__main__':
    processes = [mp.Process(target=task,args=(i,)) for i in range(1,5)]
    print(f'Start: {time.ctime()}')
    for p in processes:
        p.start()
    for p in processes:
        p.join()
    print(f'End:   {time.ctime()}')

输出：

Start: Sat Feb 15 16:32:26 2020
Task#4 started in Process-4
Task#3 started in Process-3
Task#1 started in Process-1
Task#2 started in Process-2
Task#1 done
Task#4 done
Task#3 done
Task#2 done
End:   Sat Feb 15 16:32:31 2020

在我从键盘输入任何内容后，我想在 python 中运行多个线程，但我收到此错误 - 线程 Thread-4 中的异常：

I want to run multiple threads in python after I input anthing from the keyboard and I am getting this error - Exception in thread Thread-4:

multithreading

python-multithreading

python-3.x

在我从键盘输入任何内容后，我想在 python 中 运行 多个线程，但我收到此错误 - 线程 Thread-4 中的异常：

I want to run multiple threads in python after I input anthing from the keyboard and I am getting this error - Exception in thread Thread-4:

multithreading

python-multithreading

python-3.x

在我从键盘输入任何内容后，我想在 python 中运行多个线程，但我收到此错误 - 线程 Thread-4 中的异常：