#!/usr/bin/python
#coding:utf-8
'''
线程模型,添加锁,防止数据异常
'''

import threading #线程用库
import time

num = 0
lock = threading.Lock() # 取得锁
def work1(loop):
 global num
 for i in range(loop):
 # 等价于 num += 1
 lock.acquire() # 上锁
 temp = num
 num = temp + 1
 lock.release() # 解锁
 print(num)


def work2(loop):
 global num
 for i in range(loop):
 # 等价于 num += 1
 lock.acquire() # 上锁
 temp = num
 num = temp + 1
 lock.release() # 解锁
 print(num)


if __name__ == '__main__':
 t1 = threading.Thread(target=work1,args=(1000000,))
 t2 = threading.Thread(target=work2, args=(1000000,))
 t1.start()
 t2.start()

 while len(threading.enumerate()) != 1:
 time.sleep(1)
 print(num)