python之迭代锁与信号量

如果现在需要在多处加锁大于等于2的时候因为计算机比较笨，当他锁上一把锁的时候又所理一把锁，等他来开锁的时候他不知道用哪把钥匙来开锁，

所以这个时候我们需要把把平常的锁变为迭代锁

eg：

import threading
import timelocal = threading.RLock()
# 迭代加锁首先生成实例
def run(name):global numlocal.acquire()  # 上锁num += 1run2(num)local.release()  # 解锁print(threading.active_count())def run2(num):local.acquire()num += 1run3(num)local.release()def run3(num):local.acquire()num+=1local.release()num = 0
py_res = []
for i in range(50):t = threading.Thread(target=run,args=('t%s'%i,))py_res.append(t)t.start()for i in py_res:i.join()print("num : %s"% num)

型号量可以控制同线程的个数，和锁的用法一样

import threading
import time
senm = threading.BoundedSemaphore(5)
def run(num):senm.acquire()  # 上锁time.sleep(2)print('run the thread %s' % num)senm.release()  # 解锁for i in range(50):t = threading.Thread(target=run, args=('%s' % i,))t.start()print(threading.active_count())while threading.active_count() != 1:pass
else:print('is done')

信号量：event

标志位：set，设置标志位 clear 设置标志位，wait 等带标志位，is_set 判断是否设置了标志

下面是一个红绿灯的程序，实现红灯停绿灯行

import threading
import time
event = threading.Event()
# red is have flag or nodef light():count = 0while True:if count > 5 and count <= 10:print('red')event.set()elif count > 10:print('green')event.clear()count = 0else:print('in the else')time.sleep(1)count += 1
def car(name):while True:if event.is_set():print('the %s is runing...' % name)time.sleep(1)else:print('%s is wait...' % name)event.wait()t1 = threading.Thread(target=light)
t1.start()
t2 = threading.Thread(target=car, args=('tesla', ))
t2.start()

转载于:https://www.cnblogs.com/BookMiki/p/10202613.html

python之迭代锁与信号量相关推荐

python并发编程之semaphore(信号量)_浅谈Python并发编程之进程（守护进程、锁、信号量）...
前言:本博文是对Python并发编程之进程的知识延伸,主要讲解:守护进程.锁.信号量. 友情链接: 一.守护进程(daemon) 1.1 守护进程概念首先我们都知道:正常情况下,主进程默认等待子进程 ...
递归锁、信号量、GIL锁、基于多线程的socket通信和进程池线程池
递归锁.信号量.GIL锁.基于多线程的socket通信和进程池线程池递归锁死锁现象:是指两个或两个以上的进程和线程因抢夺计算机资源而产生的一种互相等待的现象 from threading impo ...
Python 进程互斥锁 Lock - Python零基础入门教程
目录一.Python 线程互斥锁和进程互斥锁 1.创建线程互斥锁 2.创建进程互斥锁二.进程互斥锁 Lock 函数介绍三.进程互斥锁 Lock 使用案例一:使用进程,但不使用互斥锁案例二:进 ...
互斥锁、死锁、递归锁、信号量、Event
互斥锁死锁和递归锁 Semaphore信号量 Event事件互斥锁互斥锁也叫用户锁.同步锁. 在多进程/多线程程序中,当多个线程处理一个公共数据时,会有数据安全问题,唯一能保证数据安全的,就是通 ...
Linux内核中的同步原语：自旋锁，信号量，互斥锁，读写信号量，顺序锁
Linux内核中的同步原语自旋锁,信号量,互斥锁,读写信号量,顺序锁 rtoax 2021年3月在英文原文基础上,针对中文译文增加5.10.13内核源码相关内容. 1. Linux 内核中的同步原 ...
python全局解释器锁 tensorflow_想轻松复现深度强化学习论文？看这篇经验之谈
近期深度强化学习领域日新月异,其中最酷的一件事情莫过于 OpenAI和 DeepMind 训练智能体接收人类的反馈而不是传统的奖励信号.本文作者认为复现论文是提升机器学习技能的最好方式之一,所以选择了 ...
Python培训教程：什么是Python全局解释器锁(GIL)?
本期Python培训教程小编为大家带来的是关于"什么是Python全局解释器锁(GIL)?"的问题,全局解释器锁是计算机程序设计语言解释器用于同步线程的工具,使得在同一进程内任何时 ...
python之互斥锁
python之互斥锁 1.互斥锁的概念互斥锁: 对共享数据进行锁定,保证同一时刻只能有一个线程去操作. [对共享数据进行锁定可以理解为全局变量] 注意: 互斥锁是多个线程一起去抢,抢到锁的线程先执 ...
python实现迭代的快速排序（Iterative Quick Sort）
python实现迭代的快速排序(Iterative Quick Sort) 快速排序(Quicksort)是对冒泡排序算法的一种改进. 快速排序由C. A. R. Hoare在1960年提出.它的基本 ...

python之迭代锁与信号量

python之迭代锁与信号量相关推荐

最新文章

热门文章