多线程 threading

标签：start   语句   主线程   int   之间   star   end   print   for   

在Python中，同样可以实现多线程，有两个标准模块thread和threading，不过我们主要使用更高级的threading模块。
一、先来看一段代码

import threading
from time import ctime,sleep
def drink(func):
    for i in range(2):
        print "I was drink %s. %s" %(func,ctime())
        sleep(1)
def eat(func):
    for i in range(2):
        print "I was eat the %s! %s" %(func,ctime())
        sleep(1)
threads = []
t1 = threading.Thread(target=drink,args=(u‘牛奶‘,))
threads.append(t1)
t2 = threading.Thread(target=eat,args=(u‘面包‘,))
threads.append(t2)
if __name__ == ‘__main__‘:
    for t in threads:
        t.start()
    t.join()
    print "all over %s" %ctime()

结果：

I was drink 牛奶. Wed Jan 17 14:13:06 2018
I was eat the 面包! Wed Jan 17 14:13:06 2018
I was drink 牛奶. Wed Jan 17 14:13:07 2018
I was eat the 面包! Wed Jan 17 14:13:07 2018
all over Wed Jan 17 14:13:08 2018

start是启动线程，join是阻塞当前线程，即使得在当前线程结束时，不会退出。

Python中，默认情况下，如果不加join语句，那么主线程不会等到当前线程结束才结束，但却不会立即杀死该线程。
不加join结果：

I was drink 牛奶. Wed Jan 17 14:13:23 2018
I was eat the 面包! Wed Jan 17 14:13:23 2018 all over Wed Jan 17 14:13:23 2018
I was eat the 面包! Wed Jan 17 14:13:24 2018I was drink 牛奶. Wed Jan 17 14:13:24 2018

但如果为线程实例添加t.setDaemon(True)之后，如果不加join语句，那么当主线程结束之后，会杀死子线程。

import threading
from time import ctime,sleep

def drink(func):
    for i in range(2):
        print "I was drink %s. %s" %(func,ctime())
        sleep(1)

def eat(func):
    for i in range(2):
        print "I was eat the %s! %s" %(func,ctime())
        sleep(1)

threads = []

t1 = threading.Thread(target=drink,args=(u‘牛奶‘,))
threads.append(t1)
t2 = threading.Thread(target=eat,args=(u‘面包‘,))
threads.append(t2)

if __name__ == ‘__main__‘:
    for t in threads:
        t.setDaemon(True)
        t.start()
    print "all over %s" %ctime()

不加join结果：

I was drink 牛奶. Wed Jan 17 14:10:43 2018
all over Wed Jan 17 14:10:43 2018I was eat the 面包! Wed Jan 17 14:10:43 2018

如果加上join,并设置等待时间，就会等待线程一段时间再退出。

import threading
from time import ctime,sleep

def drink(func):
    for i in range(2):
        print "I was drink %s. %s" %(func,ctime())
        sleep(1)

def eat(func):
    for i in range(2):
        print "I was eat the %s! %s" %(func,ctime())
        sleep(1)

threads = []

t1 = threading.Thread(target=drink,args=(u‘牛奶‘,))
threads.append(t1)
t2 = threading.Thread(target=eat,args=(u‘面包‘,))
threads.append(t2)

if __name__ == ‘__main__‘:
    for t in threads:
        t.setDaemon(True)
        t.start()
    t.join(0.1)
    print "all over %s" %ctime()

这里设置为0.1秒结果如下：

I was drink 牛奶. Wed Jan 17 14:11:08 2018
I was eat the 面包! Wed Jan 17 14:11:08 2018
all over Wed Jan 17 14:11:08 2018

#注释：
join()方法的位置是在for循环外的，也就是说必须等待for循环里的两个进程都结束后，才去执行主进程。

多线程 threading

标签：start   语句   主线程   int   之间   star   end   print   for   

原文地址：http://blog.51cto.com/syklinux/2062162