Python 多线程（threading模块）

首先，自己区分单线程和多线程的概念，自己去搜

单线程的例子如下：

[python] view
plaincopyprint?

__author__ = 'MrChen'



import threading

from time import ctime, sleep

#单线程

def music(music_name, length):

for i in range(4):

print('I was listening to %s %s' % (music_name, ctime()))

sleep(length)



def movie(movie_name, length):

for i in range(2):

print('I was at the movie %s %s' % (movie_name, ctime()))

sleep(length)



if __name__ == '__main__':

music('腐草为萤', 2)

movie('大话西游', 4)

print('all over %s' % ctime())

运行结果如下：

[python] view
plaincopyprint?

I was listening to 腐草为萤 Sun Oct 26 13:07:51 2014

I was listening to 腐草为萤 Sun Oct 26 13:07:53 2014

I was listening to 腐草为萤 Sun Oct 26 13:07:55 2014

I was listening to 腐草为萤 Sun Oct 26 13:07:57 2014

I was at the movie 大话西游 Sun Oct 26 13:07:59 2014

I was at the movie 大话西游 Sun Oct 26 13:08:03 2014

all over Sun Oct 26 13:08:07 2014

多线程的例子如下：

[python] view
plaincopyprint?

__author__ = 'MrChen'



import threading

from time import ctime, sleep

#多线程

def music(music_name, length):

for i in range(4):

print('I was listening to %s %s' % (music_name, ctime()))

sleep(length)



def movie(movie_name, length):

for i in range(2):

print('I was at the movie %s %s' % (movie_name, ctime()))

sleep(length)





th1 = threading.Thread(target=music, args=('腐草为萤',1))

th2 = threading.Thread(target=movie, args=('大话西游',2))

threads = [th1, th2]





if __name__ == '__main__':

for t in threads:

t.setDaemon(True)

t.start()

t.join()

print('all over %s' % ctime())

运行结果如下：

[python] view
plaincopyprint?

I was listening to 腐草为萤 Sun Oct 26 13:09:16 2014

I was at the movie 大话西游 Sun Oct 26 13:09:16 2014

I was listening to 腐草为萤 Sun Oct 26 13:09:17 2014

I was listening to 腐草为萤 Sun Oct 26 13:09:18 2014

I was at the movie 大话西游 Sun Oct 26 13:09:18 2014

I was listening to 腐草为萤 Sun Oct 26 13:09:19 2014

all over Sun Oct 26 13:09:20 2014

threading是python标准库中的模块，有些朋友查到会有thread这个模块，但是在python3里面只剩下threading这个模块了，因为threading模块用起来更简单也更安全一些

至于time模块，以后再讲，这里只需要知道time模块中有ctime()，sleep()等函数即可，ctime()返回当前时间，用一个str表示，sleep(n)表示挂起n秒



下面重点解释上面代码是怎么回事：



import threading

导入threading模块



th1 = threading.Thread(target=music, args=('腐草为萤',1))

创建一个线程th1，threading.Thread()是一个类，类的构造函数原型如下：

class threading.Thread(group=None,target=None, name=None, args=(), kwargs={}, *, daemon=None)

这里用到了target，表示要调用的函数名，args表示调用函数的参数



threads = [th1, th2]

将两个线程放入一个列表中



for t in threads:

t.setDaemon(True)

t.start()

t.join()

最后使用一个for循环，依次将列表中的线程开启

t.setDaemon(True)

将线程声明为守护线程，必须在start() 方法调用之前设置，如果不设置为守护线程程序会被无限挂起。子线程启动后，父线程也继续执行下去，当父线程执行完最后一条语句print "all over %s" %ctime()后，没有等待子线程，直接就退出了，同时子线程也一同结束。

t.start()

开始线程活动。

t.join()

join()方法，用于等待线程终止。join（）的作用是，在子线程完成运行之前，这个子线程的父线程将一直等待。

注意: join()方法的位置是在for循环外的，也就是说必须等待for循环里的两个进程都结束后，才去执行主进程。如果没有join()函数，那么父线程执行完之后就会立即结束，不会等待子线程执行完