点击上方蓝色文字一键关注

点击上方“python学习专栏”，选择“置顶公众号”

干货、福利第一时间送达！

如何开启多线程？

1、定义自己的函数

2、加入线程

3、启动线程

4、等待线程结束

看下面的代码

from threading import Threadimport time# 定义一个函数，等待5秒后输出datadef fun():data = "123"time.sleep(5)print(data)return dataif __name__ == "__main__":#定义一个线程，target为需要执行的目标函数T = Thread(target=fun)# 启动子线程T.start()print("结束")# 输出结果为# 结束# 123

假设这里不加入多线程，而是直接调用，那么输出应该是

123

结束

分析一下过程，if _name__ == "__main__" 相当于一个主线程，而 T 是我们定义的一个子线程，T.start(),开启子线程。

由于这里没有规定，让主线程等待子线程结束，因此会提前输出 结束

开启主线程等待

from threading import Threadimport time# 定义一个函数，等待5秒后输出datadef fun():data = "123"time.sleep(5)print(data)return dataif __name__ == "__main__":#定义一个线程，target为需要执行的目标函数T = Thread(target=fun)# 启动子线程T.start()# 主线程需要等待子线程结束T.join()print("结束")# 输出结果为# 123# 结束

这里只是简单的讲一下线程的操作

如何获取线程中产生的值

首先需要说一下，在线程中，使用return 返回值是不能实现的，你不能拿到这个值，无论你是否开启线程等待。可以自行尝试一下

想要实现这个功能，有两个方法，

1、重写

Thread

重写 Thread，在内部定义一个获取值的函数

import threadingclass MyThread(threading.Thread):"""重写多线程，使其能够返回值"""def __init__(self, target=None, args=()):super(MyThread, self).__init__()self.func = targetself.args = argsdef run(self):self.result = self.func(*self.args)#该函数用于获取返回值，需要开启joindef get_result(self):try:return self.resultexcept Exception:return None

使用自定义的类来实现

from threading import Threadimport time# 定义一个函数，等待5秒后返回datadef fun():data = "123"time.sleep(5)return dataif __name__ == "__main__":#定义一个线程，target为需要执行的目标函数T = MyThread(target=fun)# 启动子线程T.start()# 主线程需要等待子线程结束T.join()# 获取值必须放在 join后面，print(T.get_result())print("结束")# 输出结果为# 123# 结束

join是让主线程等待子线程结束，如果将获取结果放到了主线程join前，此时程序为运行结束，返回值为空

2、使用队列实现

首先定义一个全局队列，将多线程产生的值放到队列中，然后再主线程中获取。

from threading import Threadfrom queue import Queueimport time# 定义一个全局队列,先进先出队列queue_data = Queue()# 定义一个函数，等待5秒后输出datadef fun():data = "123"time.sleep(5)# 将数据压入队列queue_data.put(data)if __name__ == "__main__":#定义一个线程，target为需要执行的目标函数T = Thread(target=fun)# 启动子线程T.start()w = T.join()print(queue_data.get())print("结束")# 输出结果为# 123# 结束

借助concurrent模块，加入线程池中来实现

通过线程池的自带函数获取结果

from threading import Threadfrom queue import Queuefrom concurrent.futures import ThreadPoolExecutorimport time# 定义一个全局队列,先进先出队列queue_data = Queue()pool = ThreadPoolExecutor()# 定义一个函数，等待5秒后输出datadef fun():data = "123"time.sleep(5)# 将数据压入队列queue_data.put(data)return dataif __name__ == "__main__":#定义一个线程，target为需要执行的目标函数t = pool.submit(fun)print(t.result())print("结束")# 输出结果为# 123# 结束

判断线程是否结束

from threading import Threadfrom queue import Queuefrom concurrent.futures import ThreadPoolExecutorimport time# 定义一个全局队列,先进先出队列queue_data = Queue()pool = ThreadPoolExecutor()# 定义一个函数，等待5秒后输出datadef fun():data = "123"time.sleep(5)# 将数据压入队列queue_data.put(data)return dataif __name__ == "__main__":#定义一个线程，target为需要执行的目标函数t = pool.submit(fun)# 判断线程是否结束print(t.done())print("结束")# 输出结果为# False# 结束

通过判断线程是否结束，采用while循环最终获取结果

点赞+关注

END

扫描识别二维码

带你领略不一样的python