python使用多线程实例讲解

提及多线程,你须要知道多进程和多线程的区别,了解多线程的概念,至于这两点,我不打算在本片文章中详述了,不错,由于我懒得整理。。。不了解的请先问度娘python


一、普通的单线程:


打个比方,我想作听音乐和敲代码两件事儿,那么若是大脑简单的话必定要先排一下顺序编程


# 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循环敲了两遍。
数组

运行结果:多线程



那么我想告诉大家我听的什么歌、敲了什么代码。下面我将代码进行一个优化,用参数来控制歌曲和代码app

# 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

二、多线程

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


更多参考资料: