作者:也碎羽落 | 来源:互联网 | 2023-07-06 12:17
说起多线程,你需要知道多进程和多线程的区别,了解多线程的概念,至于这两点,我不打算在本片文章中详述了,不错,因为我懒得整理。。。不了解的请先问度娘1、普通的单线程:打个比方,我想做
说起多线程,你需要知道多进程和多线程的区别,了解多线程的概念,至于这两点,我不打算在本片文章中详述了,不错,因为我懒得整理。。。不了解的请先问度娘
1、普通的单线程:
打个比方,我想做听音乐和敲代码两件事儿,那么如果大脑简单的话一定要先排一下顺序
# coding=utf-8
from time import ctime,sleep
def music():
for i in range(2):
print "I was listening to music . %s" %ctime()
sleep(1)
def coding():
for i in range(2):
print "I was coding codes! %s" %ctime()
sleep(5)
if __name__ =='__main__':
music()
coding()
print " all over %s" %ctime()
我们先听了一首音乐,通过for循环来控制音乐的播放了两次,每首音乐播放需要1秒钟,sleep()来控制音乐播放的时长。接着我又敲了会代码,因为比较苦逼,每段代码需要5秒钟,通过for循环敲了两遍。
运行结果:
那么我想告诉你们我听的什么歌、敲了什么代码。下面我将代码进行一个优化,用参数来控制歌曲和代码
# coding=utf-8
from time import ctime,sleep
def music(name):
for i in range(2):
print "I was listening to music . %s %s" %(name,ctime())
sleep(1)
def coding(code):
for i in range(2):
print "I was coding codes! %s %s" %(code,ctime())
sleep(5)
if __name__ =='__main__':
music(u'伟大的闯爷')
coding(u'python代码')
print " all over %s" %ctime()
结果:
vagrant@homestead:~/release/python$ python xiancheng.py
I was listening to music . 伟大的闯爷 Wed Jul 5 03:30:05 2017
I was listening to music . 伟大的闯爷 Wed Jul 5 03:30:06 2017
I was coding codes! python代码 Wed Jul 5 03:30:07 2017
I was coding codes! python代码 Wed Jul 5 03:30:12 2017
all over Wed Jul 5 03:30:17 2017
2、多线程
python提供了两个模块来实现多线程thread 和threading ,thread 有一些缺点,在threading 得到了弥补,为了不浪费你和时间,所以我们直接学习threading 就可以了。继续对上面的例子进行改造,引入threadring来同时播放音乐和写代码:
# coding=utf-8
#
# 首先导入threading 模块,这是使用多线程的前提。
import threading
from time import ctime,sleep
def music(name):
for i in range(2):
print "I was listening to music . %s %s" %(name,ctime())
sleep(1)
def coding(code):
for i in range(2):
print "I was coding codes! %s %s" %(code,ctime())
sleep(5)
threads = []
#创建了threads数组,创建线程t1,使用threading.Thread()方法,
#在这个方法中调用music方法target=music,args方法对music进行传参。 把创建好的线程t1装到threads数组中。
#定义单元素的tuple有歧义,所以 Python 规定,单元素 tuple 要多加一个逗号“,”,这样就避免了歧义:
t1 = threading.Thread(target=music,args=(u'伟大的闯爷之歌',))
threads.append(t1)
#接着以同样的方式创建线程t2,并把t2也装到threads数组。
t2 = threading.Thread(target=coding,args=(u'python代码',))
threads.append(t2)
if __name__ =='__main__':
for t in threads:
#setDaemon(True)将线程声明为守护线程,必须在start() 方法调用之前设置,如果不设置为守护线程程序会被无限挂起。
#子线程启动后,父线程也继续执行下去,
#当父线程执行完最后一条语句print "all over %s" %ctime()后,没有等待子线程,直接就退出了,同时子线程也一同结束。
t.setDaemon(True);
#开始线程活动
t.start()
print " all over %s" %ctime()
运行结果:
I was listening to music . 伟大的闯爷之歌 Wed Jul 5 03:53:03 2017
all over Wed Jul 5 03:53:03 2017
从执行结果来看,子线程(muisc 、coding)和主线程(print “all over %s” %ctime())都是同一时间启动,但由于主线程执行完结束,所以导致子线程也终止。
继续调整程序:
...
if __name__ =='__main__':
for t in threads:
#setDaemon(True)将线程声明为守护线程,必须在start() 方法调用之前设置,如果不设置为守护线程程序会被无限挂起。
#子线程启动后,父线程也继续执行下去,
#当父线程执行完最后一条语句print "all over %s" %ctime()后,没有等待子线程,直接就退出了,同时子线程也一同结束。
t.setDaemon(True);
#开始线程活动
t.start()
t.join()
print " all over %s" %ctime()
我们只对上面的程序加了个join()方法,用于等待线程终止。join()的作用是,在子线程完成运行之前,这个子线程的父线程将一直被阻塞。
注意: join()方法的位置是在for循环外的,也就是说必须等待for循环里的两个进程都结束后,才去执行主进程。
运行结果:
I was listening to music . 伟大的闯爷之歌 Wed Jul 5 03:59:22 2017
I was coding codes! python代码 Wed Jul 5 03:59:22 2017
I was listening to music . 伟大的闯爷之歌 Wed Jul 5 03:59:23 2017
I was coding codes! python代码 Wed Jul 5 03:59:27 2017
all over Wed Jul 5 03:59:32 2017
可以看到一共消耗的时间为10s完成 ,取决于消耗时间最大的线程
在来一次,将音乐的时间调整为sleep 4秒 运行结果:
I was listening to music . 伟大的闯爷之歌 Wed Jul 5 04:09:05 2017
I was coding codes! python代码 Wed Jul 5 04:09:05 2017
I was listening to music . 伟大的闯爷之歌 Wed Jul 5 04:09:09 2017
I was coding codes! python代码 Wed Jul 5 04:09:10 2017
all over Wed Jul 5 04:09:15 2017
消耗的时间仍然为10s
更多参考资料:
1:多线程编程之thread和threading
2:多线程还是多进程的选择及区别