本文最后更新于:2024年5月7日 下午

有时需要程序异步执行,本文记录 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 sleep


def 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 sleep


def 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/


“觉得不错的话,给点打赏吧 ୧(๑•̀⌄•́๑)૭”

微信二维码

微信支付

支付宝二维码

支付宝支付

Python 异步执行 Threading
https://www.zywvvd.com/notes/coding/python/asyncio/threading/
作者
Yiwei Zhang
发布于
2023年2月13日
许可协议