python3 多线程
0 / 0 / 创建于 5年前 /
Bgods 的个人博客
一、线程模块#
Python3 通过两个标准库 _thread 和 threading 提供对线程的支持。
_thread 提供了低级别的、原始的线程以及一个简单的锁，它相比于 threading 模块的功能还是比较有限的。
threading 模块除了包含 _thread 模块中的所有方法外，还提供的其他方法：
- threading.currentThread (): 返回当前的线程变量。
- threading.enumerate (): 返回一个包含正在运行的线程的 list。正在运行指线程启动后、结束前，不包括启动前和终止后的线程。
- threading.activeCount (): 返回正在运行的线程数量，与 len (threading.enumerate ()) 有相同的结果。
除了使用方法外，线程模块同样提供了 Thread 类来处理线程，Thread 类提供了以下方法:
- run (): 用以表示线程活动的方法。
- start (): 启动线程活动。
- join ([time]): 等待至线程中止。这阻塞调用线程直至线程的 join () 方法被调用中止 - 正常退出或者抛出未处理的异常 - 或者是可选的超时发生。
- isAlive (): 返回线程是否活动的。
- getName (): 返回线程名。
- setName (): 设置线程名。
二、线程同步#
如果多个线程共同对某个数据修改，则可能出现不可预料的结果，为了保证数据的正确性，需要对多个线程进行同步。 使用 Threading 对象的 Lock 和 Rlock 可以实现简单的线程同步，这两个对象都有 acquire 方法和 release 方法，对于那些需要每次只允许一个线程操作的数据，可以将其操作放到 acquire 和 release 方法之间。
利用线程同步，可以使部分代码只能同时被一个线程操作，当这部分代码被一个线程使用时，其他线程需要等待线程该线程处理完之后，才能轮到下一个线程调用
- 实例
利用多线程，每个线程获取全局变量 num，然后对 num 进行 1000000 次的 + 1 操作，如果没有利用线程同步，代码如下：
import threading
num = 0 # 全局变量
def sum(threadName,number):
global num
for i in range(number):
num += 1
print('{} num的值是: {}'.format(threadName,num))
class myThread(threading.Thread):
def __init__(self,number):
threading.Thread.__init__(self)
self.number = number
def run(self):
print('开始线程:%s' % (self.getName()))
sum(self.getName(),self.number)
print('结束线程:%s' % (self.getName()))
if __name__ == '__main__':
threads = [] # 创建线程列表
# 创建新线程
thread1 = myThread(number=1000000)
thread2 = myThread(number=1000000)
# 添加线程到线程列表
threads.append(thread1)
threads.append(thread2)
[t.start() for t in threads] # 开启新线程
[t.join() for t in threads] # 等待所有线程完成
print('最后num的值是: {}'.format(num))运行结果如下，可以看到两个线程对 num 进行操作后，最后全局变量 num 的值是 1359993，和我们预想的结果 (2000000) 不一致。
开始线程:Thread-1
开始线程:Thread-2
Thread-1 num的值是: 1089741
结束线程:Thread-1
Thread-2 num的值是: 1359993
结束线程:Thread-2
最后num的值是: 1359993下面我们利用线程同步，对上面代码进行改进，加入以下三行代码：
...
def run(self):
threadlock.acquire() # 获取锁，用于线程同步：当线程2进入时，如果以下代码有线程1在调用，则会暂停线程2，等待线程1解锁后再到线程2进入
print('开始线程:%s' % (self.getName()))
sum(self.getName(),self.number)
threadlock.release() # 解锁线程：当线程1解锁后，线程2才能继续运行
print('结束线程:%s' % (self.getName()))
if __name__ == '__main__':
threadlock = threading.Lock() # 创建线程锁
...运行结果如下:
开始线程:Thread-1
Thread-1 num的值是: 1000000
结束线程:Thread-1
开始线程:Thread-2
Thread-2 num的值是: 2000000
结束线程:Thread-2
最后num的值是: 2000000可以看到，和我们预想的结果一致。
本作品采用《CC 协议》，转载必须注明作者和本文链接
关于 LearnKu
粤公网安备 44030502004330号
推荐文章：