python多线程threading模块

当我们要求程序并发或者需要执行多个独立的子任务的时候可以使用多线程

01.全局解释器锁GIL

目前python解释器同时只能执行一个线程,多线程环境中,只有一个线程能获得GIL,每个线程执行一段时间后释放GIL交给其他线程
因此,python的多线程只能利用cpu的一个核,GIL会在IO调用前被释放,适用于IO密集型任务。

02.退出线程

————在python中,你可以启动一个线程,但却无法停止它

当线程完成函数的执行时,它就会退出,或者调用thread.exit()之类的方法可以退出,但是不能像进程(kill pid)一样直接关闭。

03.threading模块

python中有thread和threading两个模块可以创建线程。thread功能简单,threading更高级,功能更全面更好用。
新手应该避免使用thread模块,python3中thread模块已经更名为_thread
如下

# python3.7
import thread

---------------------------------------------------------------------------

ModuleNotFoundError                       Traceback (most recent call last)

<ipython-input-3-e75c663b2a08> in <module>
----> 1 import thread


ModuleNotFoundError: No module named 'thread'

守护线程的概念:
避免使用_thread模块的一个原因是,_thread模块不支持守护线程,当主线程退出时,其他线程自动跟着退出,不论是否在工作
threading模块支持守护线程。可以为子线程设置守护线程标记,当标记值为True时(thread.daemon=true),表明该线程是不重要的。整个python程序会在所有非守护线程退出后才退出。也就是说使用threading模块不进行任何设置,python的主线程也不会突然结束。
使用Thread类创建线程,通常会有以下三种方式:

  1. 创建Thread的类的实例,传给它一个函数
  2. 创建Thread类的实例,传给它一个可调用的类实例
  3. 派生Thread的子类,并创建子类的实例
    通常我们会选择1,3两种方式
    下面用一个简单的例子方便理解
    首先是创建Thread的实例,传给它一个函数的方法
# python3.7
import threading
import time

def test_thread(id,seconds):
    print ('start thread',id,'at:',time.ctime())
    time.sleep(seconds)
    print('end thread',id,'at:',time.ctime())
    
    
def main():
    sleep_time = [3,5,7,1,9]
    # 存放线程的list
    threads=[]
    
    print('starting threads at',time.ctime())
    # 创建线程的thread实例加入列表
    for index,seconds in  enumerate(sleep_time):
        t = threading.Thread(target=test_thread,args=(index,seconds))
        threads.append(t)
    # 遍历列表,启动线程
    for t in threads:
        t.start()
#         join方法作用是,让主线程等待该线程结束,所以join应该放在下面的循环里,放在这里就会导致这个启动线程的循环阻塞。结果就是顺序执行。
#         join也可以设置超时时间
#         join函数只在主线程只进行等待的时候有用,如果主线程还有其他事情,没必要调用join阻塞自己。
#         t.join()
    for t in threads:
        t.join()
    print('all threads finished')
if __name__=='__main__':
    main()
starting threads at Fri Jun  7 15:02:27 2019
start thread 0 at: Fri Jun  7 15:02:27 2019
start thread 1 at: Fri Jun  7 15:02:27 2019
start thread 2 at: Fri Jun  7 15:02:27 2019
start thread 3 at: Fri Jun  7 15:02:27 2019
start thread 4 at: Fri Jun  7 15:02:27 2019
end thread 3 at: Fri Jun  7 15:02:28 2019
end thread 0 at: Fri Jun  7 15:02:30 2019
end thread 1 at: Fri Jun  7 15:02:32 2019
end thread 2 at: Fri Jun  7 15:02:34 2019
end thread 4 at: Fri Jun  7 15:02:36 2019
all threads finished
# 创建Thread的实例,传给它一个可调用的类的实例。
# python3.7
import threading
import time
class ThreadFunc(object):
    def __init__(self,func,args,name=''):
        self.name=name
        self.func=func
        self.args=args
    def __call__(self):
#         *作用是解包操作符,把参数元组分开成为一个个参数传递
        self.func(*self.args)
        
def test_thread(id,seconds):
    print ('start thread',id,'at:',time.ctime())
    time.sleep(seconds)
    print('end thread',id,'at:',time.ctime())

def main():
    sleep_time = [3,5,7,1,9]
    threads=[]
    print('starting threads at',time.ctime())
    
    for index,seconds in  enumerate(sleep_time):
        t = threading.Thread(target=ThreadFunc(test_thread,(index,seconds),test_thread.__name__))
        threads.append(t)
    # 遍历列表,启动线程
    for t in threads:
        t.start()

    for t in threads:
        t.join()
    print('all threads finished')
if __name__=='__main__':
    main()
starting threads at Fri Jun  7 15:08:02 2019
start thread 0 at: Fri Jun  7 15:08:02 2019
start thread 1 at:start thread 2 at:  Fri Jun  7 15:08:02 2019start thread 3 at: Fri Jun  7 15:08:02 2019
Fri Jun  7 15:08:02 2019
start thread 4 at:
 Fri Jun  7 15:08:02 2019
end thread 3 at: Fri Jun  7 15:08:03 2019
end thread 0 at: Fri Jun  7 15:08:05 2019
end thread 1 at: Fri Jun  7 15:08:07 2019
end thread 2 at: Fri Jun  7 15:08:09 2019
end thread 4 at: Fri Jun  7 15:08:11 2019
all threads finished
# 派生Thread的子类,并创建子类的实例
# python3.7
import threading
import time
class MyThread(threading.Thread):
    def __init__(self,func,args,name=''):
        threading.Thread.__init__(self)
        self.name=name
        self.func=func
        self.args=args
    def run(self):
#         *作用是解包操作符,把参数元组分开成为一个个参数传递
        self.func(*self.args)
        
def test_thread(id,seconds):
    print ('start thread',id,'at:',time.ctime())
    time.sleep(seconds)
    print('end thread',id,'at:',time.ctime())

def main():
    sleep_time = [3,5,7,1,9]
    threads=[]
    print('starting threads at',time.ctime())
    
    for index,seconds in  enumerate(sleep_time):
        t = MyThread(test_thread,(index,seconds),test_thread.__name__)
        threads.append(t)
    # 遍历列表,启动线程
    for t in threads:
        t.start()

    for t in threads:
        t.join()
    print('all threads finished')
if __name__=='__main__':
    main()
starting threads at Fri Jun  7 15:17:06 2019
start thread 0start thread 1 at: Fri Jun  7 15:17:06 2019
 at: Fri Jun  7 15:17:06 2019
start thread 2 at: Fri Jun  7 15:17:06 2019
start thread 3 at: Fri Jun  7 15:17:06 2019
start thread 4 at: Fri Jun  7 15:17:06 2019
end thread 3 at: Fri Jun  7 15:17:07 2019
end thread 0 at: Fri Jun  7 15:17:09 2019
end thread 1 at: Fri Jun  7 15:17:11 2019
end thread 2 at: Fri Jun  7 15:17:13 2019
end thread 4 at: Fri Jun  7 15:17:15 2019
all threads finished

可以看出,方式3和方式2的区别是,构造函数要调用基类的构造函数,call方法改为run方法
相比于传递函数的方式一,传递类可以封装一些参数和方法。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,875评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,569评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,475评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,459评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,537评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,563评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,580评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,326评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,773评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,086评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,252评论 1 343
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,921评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,566评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,190评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,435评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,129评论 2 366
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,125评论 2 352

推荐阅读更多精彩内容