Python 异步执行 Threading
Yiwei Zhang
·
2023-02-13
·
via 又见苍岚
有时需要程序异步执行，本文记录 Python 通过多线程实现异步执行的方法。
简介
- 异步执行模式，是指语句在异步执行模式下，各语句执行结束的顺序与语句执行开始的顺序并不一定相同。
- 同步执行时任务需要顺序执行，后续任务需要先置任务执行完成后才能运行；异步任务则是后续任务不需要等到先置任务返回结果，自顾自就运行起来的一种任务调度方式，通过状态、通知、回调来通知调用者处理结果，常用于高并发的服务请求任务以及IO密集型任务的并行加速。
- 异步执行方式使应用程序能摆 脱单个任务的牵制，提高了灵活性和应用程序的执行效率。但异步执行模式也存在一些问题，如它增加了编程的复杂性，特别是编写互用性(interoperable)要求较高 的程序。
Threading 实现异步运行
- 可以通过多线程实现任务异步执行，原理是当前任务直接开一个线程去干，自己去处理后面的任务，示例代码：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
| from threading import Thread
from time import sleepdef async_call(fn):
def wrapper(*args, **kwargs):
Thread(target=fn, args=args, kwargs=kwargs).start() return wrapper @async_call
def A():
# self.__count += 1
print("现在在执行A函数")
print('A函数睡眠3秒钟')
sleep(3)
print("A函数执行完毕")
return def B():
print("现在在执行B函数") if __name__ == "__main__":
A()
B()
|
-
输出
1
2
3
4
| 现在在执行B函数
现在在执行A函数
A函数睡眠3秒钟
A函数执行完毕
|
由于 A 在运行中创建线程有些开销，导致 B 反倒先执行了，也表示异步执行可能会发生一些奇怪的事。
-
多线程可以嵌套创建实现嵌套异步任务
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
| from threading import Thread
from time import sleepdef async_call(fn):
def wrapper(*args, **kwargs):
Thread(target=fn, args=args, kwargs=kwargs).start() return wrapper @async_call
def C():
# self.__count += 1
print("现在在执行C函数")
print('C函数睡眠1秒钟')
sleep(2)
print("C函数执行完毕")
return @async_call
def A():
# self.__count += 1
print("现在在执行A函数")
print('A函数睡眠3秒钟')
C()
sleep(3)
print("A函数执行完毕")
return def B():
print("现在在执行B函数") if __name__ == "__main__":
A()
B()
|
-
输出
1
2
3
4
5
6
7
| 现在在执行B函数
现在在执行A函数
A函数睡眠3秒钟
现在在执行C函数
C函数睡眠1秒钟
C函数执行完毕
A函数执行完毕
|
参考资料
文章链接：
https://www.zywvvd.com/notes/coding/python/asyncio/threading/
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。
