1

2

3

4

5

6

7

8

mutex = threading.Lock()

#鎖的使用

#建立鎖

mutex = threading.Lock()

#鎖定

mutex.acquire([timeout])

#釋放

mutex.release()

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

import  threading   

import  time   

counter = 0 

counter_lock = threading.Lock() 

counter_lock2 = threading.Lock()  

counter_lock3 = threading.Lock() 

#可以使用上邊三個鎖的任何一個來鎖定資源 

class  MyThread(threading.Thread):#使用類定義thread，繼承threading.Thread 

def  __init__(self,name):   

threading.Thread.__init__(

self.name = "Thread-" + str(name) 

def run(self):   #run函式必須實現 

global counter,counter_lock #多執行緒是共享資源的，使用全域性變數 

time.sleep(1);   

if counter_lock.acquire(): #當需要獨佔counter資源時，必須先鎖定，這個鎖可以是任意的一個鎖，可以使用上邊定義的3個鎖中的任意一個 

counter += 1    

print "I am %s, set counter:%s"  % (self.name,counter)   

counter_lock.release() #使用完counter資源必須要將這個鎖開啟，讓其他執行緒使用 

if  __name__ ==  "__main__":   

for i in xrange(1,101):   

my_thread = MyThread(i) 

my_thread.start()

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

# coding : uft-8

__author__ = 'Phtih0n'

import threading, time

class MyThread(threading.Thread):

def __init__(self):

threading.Thread.__init__(self)

def run(self):

global n, lock

time.sleep(1)

if lock.acquire():

print n , self.name

n += 1

lock.release()

if "__main__" == __name__:

n = 1

ThreadList = []

lock = threading.Lock()

for i in range(1, 200):

t = MyThread()

ThreadList.append(t)

for t in ThreadList:

t.start()

for t in ThreadList:

t.join()

1

2

3

4

5

6

7

8

9

10

11

1 Thread-2

2 Thread-3

3 Thread-4

4 Thread-6

5 Thread-7

6 Thread-1

7 Thread-8

8 Thread-9

9 Thread-5

Process finished with exit code 0