python threading模块

时间：2022-06-06 08:22:39
#coding=utf-8

import threading

from time import ctime,sleep

def music(func):

    for i in range(2):

        print "I was listening to %s. %s" %(func,ctime())

        sleep(1)

def move(func):

    for i in range(2):

        print "I was at the %s! %s" %(func,ctime())

        sleep(5)

threads = []

t1 = threading.Thread(target=music,args=(u'爱情买卖',))

threads.append(t1)

t2 = threading.Thread(target=move,args=(u'阿凡达',))

threads.append(t2)

if __name__ == '__main__':

    for t in threads:

        t.setDaemon(True)

        t.start()

　　
　　 for t in threads:
　　　　 t.join()

    print "all over %s" %ctime()

threads = []

t1 = threading.Thread(target=music,args=(u'爱情买卖',))

threads.append(t1)

　　创建了threads数组，创建线程t1,使用threading.Thread()方法，在这个方法中调用music方法target=music，args方法对music进行传参。 把创建好的线程t1装到threads数组中。

　　接着以同样的方式创建线程t2，并把t2也装到threads数组。

for t in threads:

　　t.setDaemon(True)

　　t.start()

最后通过for循环遍历数组。（数组被装载了t1和t2两个线程）

setDaemon()

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

注：但是如果我们在交互模式运行该程序（比如说用IDLE直接运行），主线程只有在python退出时终止，因此t1,t2还会继续打印，如果直接运行.py文件，则不会有这个问题.

start()

开始线程活动.

join()

此处join的原理就是依次检验线程池中的线程是否结束，没有结束就阻塞直到线程结束，如果结束则跳转执行下一个线程的join函数.

相关文章