python 在threading中如何处理主进程和子线程的关系
之前用python的多线程，总是处理不好进程和线程之间的关系。后来发现了join和setDaemon函数，才终于弄明白。下面总结一下。
1.使用join函数后，主进程会在调用join的地方等待子线程结束，然后才接着往下执行。
join使用实例如下：
importtime importrandom importthreading classworker(threading.Thread): def__init__(self): threading.Thread.__init__(self) defrun(self): t=random.randint(1,10) time.sleep(t) print"Thisis"+self.getName()+";Isleep%dsecond."%(t) tsk=[] foriinxrange(0,5): time.sleep(0.1) thread=worker() thread.start() tsk.append(thread) forttintsk: tt.join() print"Thisistheendofmainthread."
运行结果如下：
#pythontestjoin.py ThisisThread-3;Isleep2second. ThisisThread-1;Isleep4second. ThisisThread-2;Isleep7second. ThisisThread-4;Isleep7second. ThisisThread-5;Isleep7second. Thisistheendofmainthread.
这里创建了5个子线程，每个线程随机等待1-10秒后打印退出；主线程分别等待5个子线程结束。最后结果是先显示各个子线程，再显示主进程的结果。
2.如果使用的setDaemon函数，则与join相反，主进程结束的时候不会等待子线程。
setDaemon函数使用实例：
importtime importrandom importthreading classworker(threading.Thread): def__init__(self): threading.Thread.__init__(self) defrun(self): t=random.randint(1,10) time.sleep(t) print"Thisis"+self.getName()+";Isleep%dsecond."%(t) tsk=[] foriinxrange(0,5): time.sleep(0.1) thread=worker() thread.setDaemon(True) thread.start() tsk.append(thread) print"Thisistheendofmainthread."
这里设置主进程为守护进程，当主进程结束的时候，子线程被中止
运行结果如下：
#pythontestsetDaemon.py
Thisistheendofmainthread.
3、如果没有使用join和setDaemon函数，则主进程在创建子线程后，直接运行后面的代码，主程序一直挂起，直到子线程结束才能结束。
importtime importrandom importthreading classworker(threading.Thread): def__init__(self): threading.Thread.__init__(self) defrun(self): t=random.randint(1,10) time.sleep(t) print"Thisis"+self.getName()+";Isleep%dsecond."%(t) tsk=[] foriinxrange(0,5): time.sleep(0.1) thread=worker() thread.start() tsk.append(thread) print"Thisistheendofmainthread."
运行结果如下：
#pythontestthread.py Thisistheendofmainthread. ThisisThread-4;Isleep1second. ThisisThread-3;Isleep7second. ThisisThread-5;Isleep7second. ThisisThread-1;Isleep10second. ThisisThread-2;Isleep10second.
补充知识：PythonThread和Process对比
原因：进程和线程的差距（方向不同，之针对这个实例）
#coding=utf-8
importlogging
importmultiprocessing
importos
importtime
fromthreadingimportThread
logging.basicConfig(
level=logging.INFO,
format="%(asctime)s【%(process)d】%(processName)s%(message)s"
)
deffunc(i):
#logging.info(f'子：{os.getpid()},\t{i}')
returnf'子：{os.getpid()},\t{i}'
defmain(ctx):
start01=time.time()
ts=[Thread(target=func,args=(i,))foriinrange(100)]
[t.start()fortints]
[t.join()fortints]
end01=time.time()-start01
logging.info(f"线程花费的时间：{end01}秒")
start02=time.time()
ps=[ctx.Process(target=func,args=(i,))foriinrange(100)]
[p.start()forpinps]
[p.join()forpinps]
end02=time.time()-start02
logging.info(f"进程花费的时间：{end02}秒")
if__name__=='__main__':
#windows启动方式
multiprocessing.set_start_method('spawn')
#获取上下文
ctx=multiprocessing.get_context('spawn')
#检查这是否是冻结的可执行文件中的伪分支进程。
ctx.freeze_support()
main(ctx)
输出：
2019-10-0614:17:22,729【7412】MainProcess线程花费的时间：0.012967586517333984秒
2019-10-0614:17:25,671【7412】MainProcess进程花费的时间：2.9418249130249023秒
以上这篇python在threading中如何处理主进程和子线程的关系就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。