Python之守护线程与锁

发布时间：2019-06-24 15:40:14编辑：auto阅读（1434）

　　# 守护线程随着子线程结束而结束,与守护进程不一样--守护进程随着主进程代码执行完毕而结束

　　# from threading import Thread

　　# import time

　　#

　　# def func1():

　　# while True:

　　# time.sleep(1)

　　# print("in func1")

　　# def func2():

　　# print('func2 start...')

　　# time.sleep(5)

　　# print('func2 end...')

　　# if __name__ == '__main__':

　　# t1 = Thread(target=func1)

　　# t1.daemon = True

　　# t1.start()

　　# t2 = Thread(target=func2)

　　# t2.start()

　　# print('主线程代码完毕')

　　'''

　　输出结果:

　　func2 start...

　　主线程代码完毕

　　in func1

　　in func1

　　in func1

　　in func1

　　func2 end...

　　'''

　　# 多线程之数据安全问题

　　# from threading import Thread

　　# import time

　　#

　　# # 模拟计算在CPU中发生的过程，且时间放大

　　# def func():

　　# global n

　　# tmp = n

　　# time.sleep(1)

　　# n = tmp - 1

　　# if __name__ == '__main__':

　　# n = 10

　　# t_lst = []

　　# for i in range(10):

　　# t = Thread(target=func)

　　# t.start()

　　# t_lst.append(t)

　　# for t in t_lst:t.join()

　　# print(n) # 9

　　# 10个线程对同一个数据执行减1操作，得到的结果却是9,发生了数据安全,因此要对数据加锁

　　# from threading import Thread

　　# from threading import Lock

　　# import time

　　#郑州不  孕 不  育 医院:http://wapyyk.39.net/zz3/zonghe/1d427.html/

　　# # 模拟计算在CPU中发生的过程，且时间放大

　　# def func(lock):

　　# global n

　　# # 请求锁

　　# lock.acquire()

　　# tmp = n

　　# time.sleep(1)

　　# n = tmp - 1

　　# # 释放锁

　　# lock.release()

　　# if __name__ == '__main__':

　　# n = 10

　　# # 实例化一个锁

　　# lock = Lock()

　　# t_lst = []

　　# for i in range(10):

　　# t = Thread(target=func,args=(lock,))

　　# t.start()

　　# t_lst.append(t)

　　# for t in t_lst:t.join()

　　# print(n) # 0 耗时10秒，相当于同步执行了

　　# 当调用多个锁的时候容易造程死锁问题

　　# from threading import Thread

　　# from threading import Lock

　　# import time

　　# # 假设一个操作需要使用两个锁,func1先调用lock1

　　# def func1(name,lock1,lock2):

　　# lock1.acquire()

　　# print('%s拿到lock1'%(name))

　　# time.sleep(1)

　　# lock2.acquire()

　　# print('%s拿到lock2'%(name))

　　# time.sleep(1)

　　# print('%s执行被锁的代码'%(name))

　　# lock2.release()

　　# print('%s释放lock2'%(name))

　　# time.sleep(1)

　　# lock1.release()

　　# print('%s释放lock1'%(name))

　　# # func2先调用lock2

　　# def func2(name,lock1,lock2):

　　# lock2.acquire()

　　# print('%s拿到lock2'%(name))

　　# time.sleep(1)

　　# lock1.acquire()

　　# print('%s拿到lock1'%(name))

　　# time.sleep(1)

　　# print('%s执行被锁的代码'%(name))

　　# lock1.release()

　　# print('%s释放lock1'%(name))

　　# time.sleep(1)

　　# lock2.release()

　　# print('%s释放lock2'%(name))

　　# if __name__ == '__main__':

　　# lock1 = Lock()

　　# lock2 = Lock()

　　# t1 = Thread(target=func1,args=('t1',lock1,lock2))

　　# t1.start()

　　# t2 = Thread(target=func2,args=('t2',lock1,lock2))

　　# t2.start()

　　'''

　　输出结果：

　　t1拿到lock1

　　t2拿到lock2

　　程序卡死--发生死锁

　　'''

　　# 针对死锁情况，可以使用递归锁解决

　　# from threading import Thread

　　# from threading import RLock

　　# import time

　　# # 假设一个操作需要使用两个锁,func1先调用lock1

　　# def func1(name,lock1,lock2):

　　# lock1.acquire()

　　# print('%s拿到lock1'%(name))

　　# time.sleep(1)

　　# lock2.acquire()

　　# print('%s拿到lock2'%(name))

　　# time.sleep(1)

　　# print('%s执行被锁的代码'%(name))

　　# lock2.release()

　　# print('%s释放lock2'%(name))

　　# time.sleep(1)

　　# lock1.release()

　　# print('%s释放lock1'%(name))

　　# # func2先调用lock2

　　# def func2(name,lock1,lock2):

　　# lock2.acquire()

　　# print('%s拿到lock2'%(name))

　　# time.sleep(1)

　　# lock1.acquire()

　　# print('%s拿到lock1'%(name))

　　# time.sleep(1)

　　# print('%s执行被锁的代码'%(name))

　　# lock1.release()

　　# print('%s释放lock1'%(name))

　　# time.sleep(1)

　　# lock2.release()

　　# print('%s释放lock2'%(name))

　　# if __name__ == '__main__':

　　# lock2 = lock1 = RLock()

　　# t1 = Thread(target=func1,args=('t1',lock1,lock2))

　　# t1.start()

　　# t2 = Thread(target=func2,args=('t2',lock1,lock2))

　　# t2.start()

　　'''

　　递归锁其实是一个锁,但是可以被多处acquire

　　'''

关键字：