Python 实现异步调用函数执行 async
在实现异步调用之前我们先进行什么是同步调用和异步调用
- 同步:是指完成事务的逻辑,先执行第一个事务,如果阻塞了,会一直等待,直到这个事务完成,再执行第二个事务,顺序执行
- 异步:是和同步相对的,异步是指在处理调用这个事务的之后,不会等待这个事务的处理结果,直接处理第二个事务去了,通过状态、通知、回调来通知调用者处理结果
分析一下,下面的例子:
定义了一个装饰器 async 和 A 、B 两个function 函数
A 里面sleep 10s , 然后打印 a function 字符串
B 里面直接打印 b function 字符串
我们顺序调用两个功能:
A()
B( )
由于函数A在睡的状态,我们又不希望程序被阻塞在函数A的睡的状态,所以我们采用异步执行,即在函数A睡的状态,让其他的任务执行。
# -*- coding: utf-8 -*-
# @File : yibu.py
# @Author : Runpeng Zhang
# @Date : 2020/1/5
# @Desc : None
from threading import Thread
from time import sleep
def async(f):
def wrapper(*args, **kwargs):
thr = Thread(target=f, args=args, kwargs=kwargs)
thr.start()
return wrapper
@async
def A():
sleep(3)
print("函数A睡了3秒钟。。。。。。")
print("a function")
def B():
print("b function")
A()
B()
实战
def async(f):
def wrapper(*args, **kwargs):
thr = Thread(target=f, args=args, kwargs=kwargs)
thr.start()
return wrapper
@async
def run_fcfs(self):
self.process_ready_list.sort(key=functools.cmp_to_key(lambda x, y: x.commit < y.commit))
for process in self.process_ready_list:
self.var_id = process.id
self.var_name = process.name
self.var_begin = self.time
self.var_source = process.source
self.var_state = 'Run'
process.state = 'Finish'
tmp = process.need
for i in range(int(process.need)):
self.time += 1
tmp -= 1
self.var_need = tmp
self.var_run = (process.need - tmp)
self.get_tree0()
sleep(1)
self.process_finish_list.append(process)
self.process_ready_list.clear()
self.get_tree_fcfs()
self.ing_init()
def get_tree0(self):
# 删除原节点
for _ in map(self.tree0.delete, self.tree0.get_children("")):
pass
self.tree0.insert("", "end", values=(
self.var_id, self.var_name, self.var_begin, self.var_run, self.var_need,
self.var_source, self.var_state))
print('tree0.after---')
self.tree0.after(500, self.get_tree)
类似于我想做一个(图形界面)逐秒+1, a = 0,再过一秒变成a=1,然后我图形Frame是设定了多少毫秒更新一下,但是如果我从a=0到a=100,但我这只是重复了time.sleep(1)一百次,实际的运行时间并没有多少毫秒来达到刷新,所以感觉我这种方式是矛盾的 !然后经过询问浩哥的建议,采用异步调用函数方式来执行。