快捷導(dǎo)航

簡(jiǎn)要講解Python編程中線程的創(chuàng)建與鎖的使用

更新時(shí)間：2016年02月28日 15:08:19 作者：pizize

這篇文章主要介紹了簡(jiǎn)要講解Python編程中線程的創(chuàng)建與鎖的使用,Python中雖然有GIL的存在,但依然是能夠創(chuàng)建多個(gè)線程來交替使用的,需要的朋友可以參考下

創(chuàng)建線程
創(chuàng)建線程的兩種方法：
1，直接調(diào)用threading.Thread來構(gòu)造thread對(duì)象，Thread的參數(shù)如下：
class threading.Thread(group=None, target=None, name=None, args=(), kwargs={})
group為None；
target為線程將要執(zhí)行的功能函數(shù)；
name為線程的名字，也可以在對(duì)象構(gòu)造后調(diào)用setName()來設(shè)定；
args為tuple類型的參數(shù)，可以為多個(gè)，如果只有一個(gè)也的使用tuple的形式傳入，例如(1,)；
kwargs為dict類型的參數(shù)，也即位命名參數(shù)
threading.Thread對(duì)象的其他方法：
start()，用來啟動(dòng)線程；
join(), 等待直到線程結(jié)束；
isAlive(),獲取線程狀態(tài)

setDeamon(), 設(shè)置線程為deamon線程，必須在start()調(diào)用前調(diào)用，默認(rèn)為非demon。
注意： python的主線程在沒有非deamon線程存在時(shí)就會(huì)退出。

threading.currentthread() , 用來獲得當(dāng)前的線程；
threading.enumerate() ，用來多的當(dāng)前存活的所有線程；

#coding:utf-8
import threading
def func1(num):
 for i in range(num):
  #threading.currentThread()獲取當(dāng)前線程，getName()獲取線程名字
  print 'I am %s.num:%s' % (threading.currentThread().getName(), i)
      
def main(thread_num):
 thread_list = [] #定義一個(gè)線程列表
 for i in range(thread_num):
  thread_list.append(threading.Thread(target=func1, args = (3, )))
 for a in thread_list:
  #a.setDaemon(True)這個(gè)setDaemon默認(rèn)為False 非守護(hù)線程
  #表示主線程等所有子線程結(jié)束后，在結(jié)束
  #設(shè)置為True的話 表示是個(gè)守護(hù)線程 子線程就會(huì)隨著主線程的結(jié)束而結(jié)束
  #聽說服務(wù)監(jiān)控工具生成的心跳線程 就是用的守護(hù)線程
  a.start()
      
      
 for a in thread_list:
  a.join() #表示等待直到線程運(yùn)行完畢
      
main(3)

運(yùn)行結(jié)果

I am Thread-1.num:0
I am Thread-1.num:1
I am Thread-1.num:2
I am Thread-2.num:0
I am Thread-2.num:1
I am Thread-2.num:2
I am Thread-3.num:0
I am Thread-3.num:1
I am Thread-3.num:2

2，直接從threading.Thread繼承，然后重寫__init__方法和run方法

#coding:utf-8
import threading
class MyThread(threading.Thread): #繼承父類threading.Thread
 def __init__(self, num ): 
  threading.Thread.__init__(self)
  self.num = num
   
 #把要執(zhí)行的代碼寫到run函數(shù)里面 線程在創(chuàng)建后會(huì)直接運(yùn)行run函數(shù) 
 def run(self):
  for i in range(self.num):
   print 'I am %s.num:%s' % (self.getName(), i)
     
for i in range(3):
 t = MyThread(3)
 t.start()
 t.join()

運(yùn)行結(jié)果

I am Thread-1.num:0
I am Thread-1.num:1
I am Thread-1.num:2
I am Thread-2.num:0
I am Thread-2.num:1
I am Thread-2.num:2
I am Thread-3.num:0
I am Thread-3.num:1
I am Thread-3.num:2

鎖的使用
假設(shè)我們有一個(gè)公共數(shù)據(jù)x(也可以叫共享資源，臨界資源)，然后跑10個(gè)線程都去訪問這變量并對(duì)這個(gè)變量進(jìn)行修改的操作，那么就得到意料之外的結(jié)果。

import threading       # 導(dǎo)入threading模塊
import time        # 導(dǎo)入time模塊
class mythread(threading.Thread):  # 通過繼承創(chuàng)建類
 def __init__(self,threadname):  # 初始化方法
  # 調(diào)用父類的初始化方法
  threading.Thread.__init__(self,name = threadname) 
 def run(self):       # 重載run方法
  global x     # 使用global表明x為全局變量
  for i in range(3):
   x = x + 1
  time.sleep(2)   # 調(diào)用sleep函數(shù)，讓線程休眠5秒
  print x
                
tl = []        # 定義列表
for i in range(10):
 t = mythread(str(i))    # 類實(shí)例化
 tl.append(t)      # 將類對(duì)象添加到列表中
               
x=0         # 將x賦值為0
for i in tl:
 i.start()       # 依次運(yùn)行線程

運(yùn)行結(jié)果

[root@localhost ~]# python syn.py

由于x是全局變量（共享資源），每個(gè)線程對(duì)x操作后就休眠了
在線程休眠的時(shí)候其他線程也都開始執(zhí)行操作，
最終休眠5秒后x的值最終就被修改為30了

使用互斥鎖來保護(hù)公共資源。用互斥鎖來保證同一時(shí)刻只有一個(gè)線程訪問公共資源,實(shí)現(xiàn)簡(jiǎn)單的同步
互斥鎖：threading.Lock
互斥鎖方法：acquire() 獲取鎖 release():釋放鎖
當(dāng)有一個(gè)線程獲的鎖之后，這把鎖就會(huì)進(jìn)入locke狀態(tài)（被鎖起來了），另外的線程試圖獲取鎖的時(shí)候就會(huì)變成同步阻塞狀態(tài)，
當(dāng)擁有線程鎖的的線程調(diào)用鎖方法 release()之后就會(huì)釋放鎖，那么鎖就會(huì)變成開鎖unlocked狀態(tài)，之后再從同步阻塞狀態(tài)的線程中選擇一個(gè)來獲得鎖

import threading       # 導(dǎo)入threading模塊
import time        # 導(dǎo)入time模塊
class mythread(threading.Thread):     # 通過繼承創(chuàng)建類
 def __init__(self,threadname):     # 初始化方法
  threading.Thread.__init__(self,name = threadname) 
 def run(self):       # 重載run方法
  global x      # 使用global表明x為全局變量
  lock.acquire()      # 調(diào)用lock的acquire方法
  for i in range(3):
   x = x + 1
  time.sleep(2)   # 調(diào)用sleep函數(shù)，讓線程休眠5秒
  print x
  lock.release()    # 調(diào)用lock的release方法
lock = threading.Lock()    # 類實(shí)例化
tl = []       # 定義列表
for i in range(10):
 t = mythread(str(i))   # 類實(shí)例化
 tl.append(t)    # 將類對(duì)象添加到列表中
       
x=0      # 將x賦值為0
for i in tl:
 i.start()      # 依次運(yùn)行線程

運(yùn)行結(jié)果：