参考博客:[https://www.bilibili.com/video/BV1fz4y1D7tU?p=9)] 黑马程序员python多线程编程
1. python多线程的介绍
多线程是python程序中实现多任务的一种方式,线程是程序执行的最小单位,同属一个进程的多个线程共享进程所拥有的全部资源。 ![在这里插入图片描述](https://img-blog.csdnimg.cn/43a57af4ecaa4691b1aedad8ef25a0d0.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center) ![在这里插入图片描述](https://img-blog.csdnimg.cn/4cd872902bd644c3ba8c1555b5d11146.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_16,color_FFFFFF,t_70,g_se,x_16#pic_center)
2. python多线程执行多任务
用多线程执行多任务,提高程序执行的效率。 ![在这里插入图片描述](https://img-blog.csdnimg.cn/ac9d60856abb4c96a76410a17ee57ae6.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center)
import time
import threading
def sing():
for i in range(3):
print("唱歌...")
time.sleep(1)
def dance():
for j in range(3):
print("跳舞...")
time.sleep(1)
if __name__=='__main__':
sing_thread = threading.Thread(target = sing )
dance_thread = threading.Thread(target = dance )
sing_thread.start()
dance_thread.start()
3. 线程执行带有参数的任务
![在这里插入图片描述](https://img-blog.csdnimg.cn/f4b847d75d7441cc94e5c3aea8f9ed6e.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center) ![在这里插入图片描述](https://img-blog.csdnimg.cn/d4cca23ad290452ebcb12bed4569549f.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center) ![在这里插入图片描述](https://img-blog.csdnimg.cn/a64f8162373c4ac18329cc70f1b45415.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center)
import time
import threading
def sing(num,name):
for i in range(num):
print(name,"唱歌...")
time.sleep(1)
def dance(count):
for j in range(count):
print("跳舞...")
time.sleep(1)
if __name__=='__main__':
sing_thread = threading.Thread(target = sing, args = (3, "xiaoming") )
dance_thread = threading.Thread(target = dance,kwargs = {"count":2} )
sing_thread.start()
dance_thread.start()
4. 主线程和子线程的结束顺序
主线程会等待所有的子线程结束才结束。
import time
import threading
def work():
for i in range (10):
print("工作...")
time.sleep(0.2)
if __name__ == '__main__':
work_thread = threading.Thread(target = work )
work_thread.start()
time.sleep(1)
print("主线程结束了")
运行结果: ![在这里插入图片描述](https://img-blog.csdnimg.cn/a7a5a72c0e714ecbaf52a2fe1dc7cccd.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_12,color_FFFFFF,t_70,g_se,x_16) 这里可以看出在主线程显示已经结束时,子线程还没有结束,最后等待子线程结束才是真正的结束。因为有主线程等待所有的子线程结束再结束,所有有了守护主线程。
![在这里插入图片描述](https://img-blog.csdnimg.cn/7d6ccf7e2fa94c60b5effe6e30ddf410.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center)
import time
import threading
def work():
for i in range (10):
print("工作...")
time.sleep(0.2)
if __name__ == '__main__':
work_thread = threading.Thread(target = work , daemon = True)
work_thread.start()
time.sleep(1)
print("主线程结束了")
执行结果: ![在这里插入图片描述](https://img-blog.csdnimg.cn/a83c2ae13a894bf2b747534ba344b9f6.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_12,color_FFFFFF,t_70,g_se,x_16) 这里通过对比就可以看出,主线程执行结束就立即结束了,不会再等待没有结束的子线程
5. 线程间的执行顺序
线程间虽然是先后启动的,但是是并行执行的。
import threading
import time
def task():
time.sleep(1)
thread = threading.current_thread()
print(thread )
if __name__ == '__main__':
for i in range(5):
task_thread = threading.Thread(target=task)
task_thread.start()
结果: ![在这里插入图片描述](https://img-blog.csdnimg.cn/dc1ef15972ab4586a749060b7bc9f107.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA5YiY5ZK46bG8,size_20,color_FFFFFF,t_70,g_se,x_16) 可以看出先后启动的,但是是并行执行的。 存在的问题:数据的共享问题 只针对cpu?
|