同一进程下的多个线程共享内存数据,多个线程之间没有主次关系,相互之间可以操作;cpu执行的都是线程,默认程序会开一个主线程;进程是程序以及和程序相关资源的集合;某些场景下我们可以使用多线程来达到提高程序执行效率的目的,下面就多线程的一些基础知识做简要说明
简单的多线程
import threading, time def test1(x): time.sleep(5) print(x**x) #下面定义两个线程调用test1这个函数,创建多线程使用如下语法,target后面跟函数名,args传递实参,实参需要以元组形式传递 start_time = time.time() t1 = threading.Thread(target=test1, args=(5,)) t2 = threading.Thread(target=test1, args=(6,)) #启动多线程 t1.start() t2.start() end_time = time.time() total_time = end_time - start_time print("two Thread used %s time"%total_time) #由于使用多线程,t1 t2启动以后并不会等待期执行完程序才继续往后走,因为主程序就是主线程和t1 t2是并行执行的,主程序执行到此t1 t2并未运行完成 time.sleep(6) #多线程启动数量比较多时可以使用for循环,多线程并行执行,打印的结果有可能不是按照启动顺序来打印的 for i in range(5): t3 = threading.Thread(target=test1, args=(i,)) t3.start() time.sleep(6)
主线程等待非主线程执行完毕才继续执行 join方法
#有些情况主线程需要子线程执行完毕后,有可能是将数据处理完毕后才执行接下来的主线程的东西 start_time1 = time.time() tl = [] #将多线程的对象存起来,用于后面join方法 for i in range(5): t4 = threading.Thread(target=test1, args=(i,)) t4.start() tl.append(t4) for t in tl: #将多线程并发join,参加join的子线程执行完毕后才继续执行下面的主线程。 t.join() end_time1 = time.time() total_time1 = end_time1 - start_time1 print(total_time1) #此次执行时间大约就是5s
#如果多个子线程一些join一些没有join主线程怎么处理???部分子线程join主线程会等join时间最长的子线程结束后才继续,未参与join的子线程仍然和主线程并行运行 t5 = threading.Thread(target=test1, args=(5,)) t6 = threading.Thread(target=test1, args=(6,)) t5.start() t6.start() t5_join_start_time = time.time() t5.join() time.sleep(10) t5_join_end_time = time.time() print("t5 join time is %s"%(t5_join_end_time - t5_join_start_time)) #实际耗时15s
守护线程 setDeamon
#守护进程,即主线程结束以后所有的其它线程也立即结束,不用等其它线程执行完毕;正常情况即使没加join主线程执行完毕当其它线程未执行完毕程序也不会退出,必须等待所有线程执行完毕程序才结束,类似主程序在末尾有默认的join def test1(x): time.sleep(5) print("i an other Thread",x**x) for i in range(5): t = threading.Thread(target=test1, args=(i,)) t.setDaemon(True) t.start() print("Main Thread is done") #整个程序结束,不会等待守护线程打印操作执行完毕就直接结束了
递归锁 Rlock
#递归锁,一个锁里面嵌套着锁,如果不使用递归锁会导致释放锁逻辑错误,整个程序就跑偏了;使用递归锁后程序会维护一个加锁 解锁的数据结构,保证释放锁不会出问题 lock = threading.Lock() def test2(): lock.acquire() print("this is test2") lock.release() def test3(): lock.acquire() print("this is test3") lock.release() def test4(): lock.acquire() test2() print("this is test4") test3() lock.release() rlock_test = threading.Thread(target=test4) rlock_test.start() while threading.active_count() != 1: print("current thread count is",threading.active_count()) #整个程序一直在打印有两个线程,非主线程的锁嵌套出问题导致无法退出,整个程序卡死 time.sleep(1)
将lock = threading.Lock()修改为lock = threading.RLock()整个程序就能正常结束;正常结束的输出如下
this is test2
this is test4
current thread count is 2
this is test3
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件!
如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
暂无“Python多线程threading join和守护线程setDeamon原理详解”评论...
更新动态
2024年11月25日
2024年11月25日
- 凤飞飞《我们的主题曲》飞跃制作[正版原抓WAV+CUE]
- 刘嘉亮《亮情歌2》[WAV+CUE][1G]
- 红馆40·谭咏麟《歌者恋歌浓情30年演唱会》3CD[低速原抓WAV+CUE][1.8G]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[320K/MP3][193.25MB]
- 【轻音乐】曼托凡尼乐团《精选辑》2CD.1998[FLAC+CUE整轨]
- 邝美云《心中有爱》1989年香港DMIJP版1MTO东芝首版[WAV+CUE]
- 群星《情叹-发烧女声DSD》天籁女声发烧碟[WAV+CUE]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[FLAC/分轨][748.03MB]
- 理想混蛋《Origin Sessions》[320K/MP3][37.47MB]
- 公馆青少年《我其实一点都不酷》[320K/MP3][78.78MB]
- 群星《情叹-发烧男声DSD》最值得珍藏的完美男声[WAV+CUE]
- 群星《国韵飘香·贵妃醉酒HQCD黑胶王》2CD[WAV]
- 卫兰《DAUGHTER》【低速原抓WAV+CUE】
- 公馆青少年《我其实一点都不酷》[FLAC/分轨][398.22MB]
- ZWEI《迟暮的花 (Explicit)》[320K/MP3][57.16MB]