Python连载36-线程数量限制、Timer、可重入锁
一、允许一个资源最多由几个线程同时进行
命令行：threading.Semaphore(个数)
代表现在最多有几个线程可以进行操作
import threadingimport time#参数定义了最多几个线程可以使用资源semaphore = threading.Semaphore(3)#这里就是指最多有三个线程可以进行操作def func():if semaphore.acquire():for i in range(2):print(threading.current_thread().getName() + "get semapore")time.sleep(5)semaphore.release()print(threading.current_thread().getName() + "release semaphore")for i in range(8):t1 = threading.Thread(target=func,args=())t1.start()
二、Timer讲解
格式：threading.Timer(时间间隔，函数）
代表这个函数在“时间间隔”的时间之后启动
def func2():print("I am running.....")time.sleep(3)print("I an done.......")if __name__ == "__main__":t2 = threading.Timer(6,func2) #代表6秒之后开始启动线程func2t2.start()i = 0while True:print("{0}*********".format(i))time.sleep(3)i += 1
三、可重入锁
1.一个锁可以被一个线程多次申请
2.主要解决递归调用的时候哦，需要申请锁的情况，可以防止被锁住，重新申请
class MyThread(threading.Thread):def run(self):global numtime.sleep(1)if mutex.acquire(1):num = num+1msg = self.name + " set num to "+str(num)print(msg)mutex.acquire()mutex.release()mutex.release()def test():for i in range(5):t3 = MyThread()t3.start()if __name__ == "__main__":num = 0mutex = threading.RLock()#可重入锁test()
四、源码
d25_4_Rlock.py
https://github.com/ruigege66/Python_learning/blob/master/d25_4_Rlock.py
2.CSDN：https://blog.csdn.net/weixin_44630050（心悦君兮君不知-睿）
3.博客园：https://www.cnblogs.com/ruigege0000/