一篇文章带你全面解析不一样的线程
共 5899字，需浏览 12分钟
·
2021-05-17 07:35
回复“书籍”即可获赠Python从入门到进阶共10本电子书
前言
在将今天的知识点之前，大家是否了解线程，进程和协程了，那我们先来初步了解下吧。
线程
中央处理器的调度单元，简单点说就是程序中的末端执行者，相当于小弟的位置。
有人说python中的线程是个鸡肋，这是因为有了GIL，但是又不是一味的鸡肋，毕竟在执行io操作时还是挺管用的，只是在执行计算时就显得不尽人意。下面我们来看下线程的具体使用方法：
1.导入线程模块：
import threading as t2.线程的用法
tt=t.Thread(group=None,target=None,name=None,args=(),kwargs={},name='',daemon=None)group:线程组，必须是Nonetarget:运行的函数args:传入函数的参数元组kwargs:传入函数的参数字典name:线程名daemon:线程是否随主线程退出而退出(守护线程)Thread方法的返回值还有以下方法：tt.start() : 激活线程，tt.getName() : 获取线程的名称tt.setName() ：设置线程的名称tt.name : 获取或设置线程的名称tt.is_alive() ：判断线程是否为激活状态tt.isAlive() ：判断线程是否为激活状态tt.setDaemon() 设置为守护线程（默认：False）tt.isDaemon() ：判断是否为守护线程tt.ident ：获取线程的标识符。只有在调用了start()方法之后该属性才有效tt.join() ：逐个执行每个线程，执行完毕后继续往下执行tt.run() ：自动执行线程对象t的方法也有：t.active_count(): 返回正在运行线程的数量t.enumerate(): 返回正在运行线程的列表t.current_thread().getName() 获取当前线程的名字t.TIMEOUT_MAX 设置t的全局超时时间
下面我们来看下吧：
3.创建线程
线程可以使用Thread方法创建，也可以重写线程类的run方法实现，线程可分为单线程和多线程。
一、使用Thread方法来创建：
1.单线程
def xc():for y in range(100):print('运行中'+str(y))tt=t.Thread(target=xc,args=()) #方法加入到线程tt.start() #开始线程tt.join() #等待子线程结束
2.多线程
def xc(num):print('运行：'+str(num))c=[]for y in range(100):tt=t.Thread(target=xc,args=(y,))tt.start() #开始线程c.append(tt) #创建列表并添加线程for x in c:x.join() #等待子线程结束
二、重写线程的类方法
1.单线程
class Xc(t.Thread): #继承Thread类def __init__(self):super(Xc, self).__init__()def run(self): #重写run方法for y in range(100):print('运行中'+str(y))x=Xc()x.start() #开始线程x.join() #等待子线程结束也可以这么写：Xc().run() 和上面的效果是一样的
2.多线程
class Xc(t.Thread): #继承Thread类def __init__(self):super(Xc, self).__init__()def run(self,num): #重写run方法print('运行：'+str(num))x=Xc()for y in range(10):x.run(y) #运行
4.线程锁
为什么要加锁，看了这个你就知道了：
多线程在运行时同时访问一个对象会产生抢占资源的情况，所以我们必须得束缚它，所以就要给他加一把锁把他锁住，这就是同步锁。要了解锁，我们得先创建锁，线程中有两种锁：Lock和RLock。
一、Lock
使用方法：
# 获取锁当获取不到锁时，默认进入阻塞状态,设置超时时间，直到获取到锁，后才继续。非阻塞时，timeout禁止设置。如果超时依旧未获取到锁，返回False。Lock.acquire(blocking=True,timeout=1)#释放锁,已上锁的锁，会被设置为unlocked。如果未上锁调用，会抛出RuntimeError异常。Lock.release()
互斥锁，同步数据，解决多线程的安全问题：
n=10lock=t.Lock()def xc(num):lock.acquire()print('运行+：'+str(num+n))print('运行-：'+str(num-n))lock.release()c=[]for y in range(10):tt=t.Thread(target=xc,args=(y,))tt.start()c.append(tt)for x in c:x.join()
这样就显得有条理了，而且输出也是先+后-。Lock在一个线程中多次使用同一资源会造成死锁。
死锁问题：
n=10lock1=t.Lock()lock2=t.Lock()def xc(num):lock1.acquire()print('运行+：'+str(num+n))lock2.acquire()print('运行-：'+str(num-n))lock2.release()lock1.release()c=[]for y in range(10):tt=t.Thread(target=xc,args=(y,))tt.start()c.append(tt)for x in c:x.join()
二、RLock
相比Lock它可以递归，支持在同一线程中多次请求同一资源，并允许在同一线程中被多次锁定，但是acquire和release必须成对出现。
使用递归锁来解决死锁：
n=10lock1=t.RLock()lock2=t.RLock()def xc(num):lock1.acquire()print('运行+：'+str(num+n))lock2.acquire()print('运行-：'+str(num-n))lock2.release()lock1.release()c=[]for y in range(10):tt=t.Thread(target=xc,args=(y,))tt.start()c.append(tt)for x in c:x.join()
这时候，输出变量就变得仅仅有条了，不在随意抢占资源。关于线程锁，还可以使用with更加方便：
#with上下文管理，锁对象支持上下文管理with lock: #with表示自动打开自动释放锁for i in range(10): #锁定期间，其他人不可以干活print(i)#上面的和下面的是等价的if lock.acquire(1):#锁住成功继续干活，没有锁住成功就一直等待，1代表独占for i in range(10): #锁定期间，其他线程不可以干活print(i)lock.release() #释放锁
三、条件锁
等待通过，Condition(lock=None),可以传入lock或者Rlock，默认Rlock，使用方法：
Condition.acquire(*args) 获取锁Condition.wait(timeout=None) 等待通知，timeout设置超时时间Condition.notify(num)唤醒至多指定数目个数的等待的线程，没有等待的线程就没有任何操作Condition.notify_all() 唤醒所有等待的线程 或者notifyAll()
def ww(c):with c:print('init')c.wait(timeout=5) #设置等待超时时间5print('end')def xx(c):with c:print('nono')c.notifyAll() #唤醒所有线程print('start')c.notify(1) #唤醒一个线程print('21')c=t.Condition() #创建条件t.Thread(target=ww,args=(c,)).start()t.Thread(target=xx,args=(c,)).start()
这样就可以在等待的时候唤醒函数里唤醒其他函数里所存在的其他线程了。
5.信号量
信号量可以分为有界信号量和无解信号量，下面我们来具体看看他们的用法：
一、有界信号量
它不允许使用release超出初始值的范围，否则，抛出ValueError异常。
#构造方法。value为初始信号量。value小于0，抛出ValueError异常b=t.BoundedSemaphore(value=1)#获取信号量时，计数器减1，即_value的值减少1。如果_value的值为0会变成阻塞状态。获取成功返回TrueBoundedSemaphore.acquire(blocking=True,timeout=None)#释放信号量，计数器加1。即_value的值加1，超过初始化值会抛出异常ValueError。BoundedSemaphore.release()#信号量，当前信号量BoundedSemaphore._value
可以看到了多了个release后报错了。
二、无界信号量
它不检查release的上限情况，只是单纯的加减计数器。
可以看到虽然多了个release，但是没有问题，而且信号量的数量不受限制。
6.Event
线程间通信，通过线程设置的信号标志(flag)的False 还是True来进行操作，常见方法有：
event.set() flag设置为Trueevent.clear() flag设置为Falseevent.is_set() flag是否为True，如果 event.isSet()==False将阻塞线程；设置等待flag为True的时长，None为无限等待。等到返回True,未等到超时则返回Falseevent.wait(timeout=None)
下面通过一个例子具体讲述：
import timee=t.Event()def ff(num):while True:if num<5:e.clear() #清空信号标志print('清空')if num>=5:e.wait(timeout=1) #等待信号标志为真e.set()print('启动')if e.isSet(): #如果信号标志为真则清除标志e.clear()print('停止')if num==10:e.wait(timeout=3)e.clear()print('退出')breaknum+=1time.sleep(2)ff(1)
设置延迟后可以看到效果相当明显，我们让他干什么事他就干什么事。
7.local
可以为各个线程创建完全属于它们自己的变量(线程局部变量)，而且它们的值都在当前调用它的线程当中，以字典的形式存在。下面我们来看下：
l=t.local() #创建一个线程局部变量def ff(num):l.x=100 #设置l变量的x方法的值为100for y in range(num):l.x+=3 #改变值print(str(l.x))for y in range(10):t.Thread(target=ff,args=(y,)).start() #开始执行线程
那么，可以将变量的x方法设为全局变量吗？我们来看下：
可以看出他报错了，产生错误的原因是因为这个类中没有属性x,我们可以简单的理解为局部变量就只接受局部。
8.Timer
设置定时计划，可以在规定的时间内反复执行某个方法。他的使用方法是：
t.Timer(num,func,*args,**kwargs) #在指定时间内再次重启程序下面我们来看下：
def f():print('start')global t #防止造成线程堆积导致最终程序退出tt= t.Timer(3, f)tt.start()f()
这样就达到了每三秒执行一次f函数的效果。
总结
通过对线程的全面解析我们了解到了线程的重要性，它可以将我们复杂的问题变得简单化，对于喜欢玩爬虫的小伙伴们可以说是相当有用了，本文基本覆盖了线程的所有概念，希望能帮到大家。
------------------- End -------------------
往期精彩文章推荐：
欢迎大家点赞，留言，转发，转载，感谢大家的相伴与支持
想加入Python学习群请在后台回复【入群】
万水千山总是情，点个【在看】行不行
/今日留言主题/
随便说一两句吧~~