Python 异步执行 Threading

有时需要程序异步执行，本文记录 Python 通过多线程实现异步执行的方法。

简介

• 异步执行模式，是指语句在异步执行模式下，各语句执行结束的顺序与语句执行开始的顺序并不一定相同。
• 同步执行时任务需要顺序执行，后续任务需要先置任务执行完成后才能运行；异步任务则是后续任务不需要等到先置任务返回结果，自顾自就运行起来的一种任务调度方式，通过状态、通知、回调来通知调用者处理结果，常用于高并发的服务请求任务以及IO密集型任务的并行加速。

• 异步执行方式使应用程序能摆 脱单个任务的牵制，提高了灵活性和应用程序的执行效率。但异步执行模式也存在一些问题，如它增加了编程的复杂性，特别是编写互用性(interoperable)要求较高 的程序。

Threading 实现异步运行

• 可以通过多线程实现任务异步执行，原理是当前任务直接开一个线程去干，自己去处理后面的任务，示例代码：

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()

• 输出

  现在在执行B函数
  现在在执行A函数
  A函数睡眠3秒钟
  A函数执行完毕

  由于 A 在运行中创建线程有些开销，导致 B 反倒先执行了，也表示异步执行可能会发生一些奇怪的事。

• 多线程可以嵌套创建实现嵌套异步任务

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()

• 输出

  现在在执行B函数
  现在在执行A函数
  A函数睡眠3秒钟
  现在在执行C函数
  C函数睡眠1秒钟
  C函数执行完毕
  A函数执行完毕

参考资料

• https://blog.csdn.net/qq_44193969/article/details/116055238
• https://baike.baidu.com/item/异步执行模式/1469800?fr=aladdin

文章链接：
https://www.zywvvd.com/notes/coding/python/asyncio/threading/