线程--守护线程线程锁信号量事件条件定时器队列池

Posted mys6

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了线程--守护线程线程锁信号量事件条件定时器队列池相关的知识,希望对你有一定的参考价值。

守护线程

技术图片

 

import time
from threading import Thread
def func1():
while True:
print(‘*‘*10)
time.sleep(1)
def func2():
print(‘in func2‘)
time.sleep(5)

t = Thread(target=func1,)
t.daemon = True
t.start()
t2 = Thread(target=func2,)
t2.start()
t2.join() #加join后会等待func2结束后在打印
print(‘主线程‘)

# 守护进程随着主进程代码的执行结束而结束
# 守护线程会在主线程结束之后等待其他子线程的结束才结束

# 主进程在执行完自己的代码之后不会立即结束 而是等待子进程结束之后 回收子进程的资源
# import time
# from multiprocessing import Process
# def func():
# time.sleep(5)
#
# if __name__ == ‘__main__‘:
# Process(target=func).start()

 

 

线程锁

技术图片

为什么Cpython自带GIL锁还出现死锁,因为是对线程GIL锁,避免不了时间片轮转带来数据不安全

 技术图片

import time
from threading import Lock,Thread
# Lock 互斥锁(只有一个钥匙)
# def func(lock):
# global n
# lock.acquire()
# temp = n
# time.sleep(0.2)
# n = temp - 1
# lock.release()
#
# n = 10
# t_lst = []
# lock = Lock()
# 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)



# 科学家吃面

# noodle_lock = Lock()
# fork_lock = Lock()
# def eat1(name):
# noodle_lock.acquire()
# print(‘%s拿到面条啦‘%name)
# fork_lock.acquire()
# print(‘%s拿到叉子了‘%name)
# print(‘%s吃面‘%name)
# fork_lock.release()
# noodle_lock.release()
#
# def eat2(name):
# fork_lock.acquire()
# print(‘%s拿到叉子了‘%name)
# time.sleep(1)
# noodle_lock.acquire()
# print(‘%s拿到面条啦‘%name)
# print(‘%s吃面‘%name)
# noodle_lock.release()
# fork_lock.release()
#
# Thread(target=eat1,args=(‘alex‘,)).start()
# Thread(target=eat2,args=(‘Egon‘,)).start()
# Thread(target=eat1,args=(‘bossjin‘,)).start()
# Thread(target=eat2,args=(‘nezha‘,)).start()
执行上面代码后出现死锁阻塞
技术图片







解决死锁问题

技术图片
from threading import RLock # 递归锁(一串钥匙,多少根据accquire多少次)
fork_lock = noodle_lock = RLock() # 一个钥匙串上的两把钥匙
def eat1(name):
noodle_lock.acquire() # 一把钥匙
print(‘%s拿到面条啦‘%name)
fork_lock.acquire()
print(‘%s拿到叉子了‘%name)
print(‘%s吃面‘%name)
fork_lock.release()
noodle_lock.release()

def eat2(name):
fork_lock.acquire()
print(‘%s拿到叉子了‘%name)
time.sleep(1)
noodle_lock.acquire()
print(‘%s拿到面条啦‘%name)
print(‘%s吃面‘%name)
noodle_lock.release()
fork_lock.release()

Thread(target=eat1,args=(‘alex‘,)).start()
Thread(target=eat2,args=(‘Egon‘,)).start()
Thread(target=eat1,args=(‘bossjin‘,)).start()
Thread(target=eat2,args=(‘nezha‘,)).start()

以上是关于线程--守护线程线程锁信号量事件条件定时器队列池的主要内容,如果未能解决你的问题,请参考以下文章

Python 多线程

13 join 线程锁之LockRlock信号量 将线程变为守护进程 Event事件  queue队列 生产者消费者模型 Queue队列 开发一个线程池

网络编程基础--多线程---concurrent.futures 模块---事件Event---信号量Semaphore---定时器Timer---死锁现象 递归锁----线程队列queue(示例代码

python中的线程(zz)

36 线程 队列 守护线程 互斥锁 死锁 可重入锁 信号量

Python与线程 𒵍