[已解决]来来，说下这个程序的运行流程

Stubborn · 发表于 2020-5-26 01:02:39

马上注册，结交更多好友，享用更多功能^_^

您需要登录才可以下载或查看，没有账号？立即注册

x

本帖最后由 Stubborn 于 2020-5-26 17:07 编辑

def apply_async(function, args, *, callback):
result = function(*args)
callback(result)
from queue import Queue
from functools import wraps
class Async:
def __init__(self, function, args):
self.function = function
self.args = args
def in_lined_async(function):
@wraps(function)
def wrapper(*args):
f = function(*args)
result_queue = Queue()
result_queue.put(None)
while True:
result = result_queue.get()
try:
a = f.send(result)
apply_async(a.function, a.args, callback=result_queue.put)
except StopIteration:
break
return wrapper
def add(x, y):
return x+y
@in_lined_async
def test():
y = yield Async(add, (2, 3))
print(y)
y = yield Async(add, ("Hello ", "World"))
print(y)
for n in range(5):
y = yield Async(add, (n, n))
print(y)
print("Goodbye")
test()

复制代码

最佳答案

月排行榜 / 总排行榜

qiuyouzhi

2021-2-2 17:02:31

本帖最后由 qiuyouzhi 于 2021-2-2 19:45 编辑

Hallo
我又来了..不知道解释的对不对
都在注释里了

def apply_async(function, args, *, callback):
result = function(*args)
callback(result)
from queue import Queue
from functools import wraps
class Async:
def __init__(self, function, args):
self.function = function
self.args = args
def in_lined_async(function):
@wraps(function) # 没啥用，防止原函数属性被覆盖
def wrapper(*args):
f = function(*args) # 调用
result_queue = Queue() # 新建一个队列
result_queue.put(None) # 这行代码一是为了防止下面的result_queue.get()卡住，二是为了使f.send(result)可以成功运行
while True:
result = result_queue.get() # 从队列里面获取一个值
try:
a = f.send(result) # a 是 Async 这个类，因为在 test 函数里面写了 yield Async(.....)
apply_async(a.function, a.args, callback = result_queue.put) # 调用这个类的function属性（它是一个函数），
# 并把 args 属性作为参数传入，并把这个函数调用后的返回值放到队列里（原因看 apply_async 的定义）
# 这一段完事后，y = yield Async(add, (2, 3)) 这段代码才正式赋值y
except StopIteration:
break
return wrapper
def add(x, y):
return x + y
@in_lined_async
def test():
y = yield Async(add, (2, 3)) # 在这里会挂住，直到调用apply_async那里才会继续
# 这里 y 之所以不是Async这个类，是因为result_queue.get()那里，于是result_queue就空了
# 这里就会堵塞住，无法继续执行，必须等到下一个值被传入
# 而像 other = yield foo 这样的语句的意思是，“返回 foo 的值，这个值返回给调用者的同时，将 other 的值也设置为那个值”。
# 来源：https://fishc.com.cn/thread-56023-1-1.html
print(y)
y = yield Async(add, ("Hello ", "World"))
print(y)
for n in range(5):
y = yield Async(add, (n, n))
print(y)
print("Goodbye")
test()

复制代码

写的有点乱，见谅

跳转到最佳答案楼层

Stubborn · 发表于 2020-5-26 01:03:45

@Twilight6 如果Twilight6帮助到了我，我会给你一个最佳的

Twilight6 · 发表于 2020-5-26 07:34:08

Stubborn 发表于 2020-5-26 01:03
@Twilight6 如果Twilight6帮助到了我，我会给你一个最佳的

我不会丫，这么多修饰符，还导入了两个我没学过的包

xiaosi4081 · 发表于 2020-5-26 07:36:18

Twilight6 发表于 2020-5-26 07:34
我不会丫，这么多修饰符，还导入了两个我没学过的包

同感

老八秘制 · 发表于 2020-5-26 07:39:56

都说了不要@人

qiuyouzhi · 发表于 2020-5-26 07:42:48

老八秘制发表于 2020-5-26 07:39
都说了不要@人

emmmm，这个不算无脑@，
算是友好交流吧

qiuyouzhi · 发表于 2020-5-26 07:44:37

这个程序会报错，说是add少了个参数y
不知道是不是我的问题

Twilight6 · 发表于 2020-5-26 07:46:04

qiuyouzhi 发表于 2020-5-26 07:44
这个程序会报错，说是add少了个参数y
不知道是不是我的问题

不是你的问题，我也报错了，但是我看不懂代码...

qiuyouzhi · 发表于 2020-5-26 07:47:48

Twilight6 发表于 2020-5-26 07:46
不是你的问题，我也报错了，但是我看不懂代码...

我表示还行

Twilight6 · 发表于 2020-5-26 07:48:36

qiuyouzhi 发表于 2020-5-26 07:47
我表示还行

快去音频问题那领鱼币哈哈

qiuyouzhi · 发表于 2020-5-26 07:53:12

Twilight6 发表于 2020-5-26 07:48
快去音频问题那领鱼币哈哈

感谢

永恒的蓝色梦想 · 发表于 2020-5-26 08:19:45

建议先改错

老八秘制 · 发表于 2020-5-26 08:37:39

qiuyouzhi 发表于 2020-5-26 07:42
emmmm，这个不算无脑@，
算是友好交流吧

女子口巴

Stubborn · 发表于 2020-5-26 17:06:32

qiuyouzhi 发表于 2020-5-26 07:44
这个程序会报错，说是add少了个参数y
不知道是不是我的问题

不好意思哈，参数收集出了点问题，代码已经修正！

Stubborn · 发表于 2020-5-26 17:07:54

永恒的蓝色梦想发表于 2020-5-26 08:19
建议先改错

不好意思哈，参数收集出了点问题，代码已经修正！

Stubborn · 发表于 2020-5-26 17:08:35

Twilight6 发表于 2020-5-26 07:46
不是你的问题，我也报错了，但是我看不懂代码...

不好意思哈，参数收集出了点问题，代码已经修正！

qiuyouzhi · 发表于 2021-2-2 17:02:31

这个最佳答案由 qiuyouzhi 给出，感谢 qiuyouzhi 的回答。

单击隐藏图章

本帖最后由 qiuyouzhi 于 2021-2-2 19:45 编辑

Hallo
我又来了..不知道解释的对不对
都在注释里了

def apply_async(function, args, *, callback):
result = function(*args)
callback(result)
from queue import Queue
from functools import wraps
class Async:
def __init__(self, function, args):
self.function = function
self.args = args
def in_lined_async(function):
@wraps(function) # 没啥用，防止原函数属性被覆盖
def wrapper(*args):
f = function(*args) # 调用
result_queue = Queue() # 新建一个队列
result_queue.put(None) # 这行代码一是为了防止下面的result_queue.get()卡住，二是为了使f.send(result)可以成功运行
while True:
result = result_queue.get() # 从队列里面获取一个值
try:
a = f.send(result) # a 是 Async 这个类，因为在 test 函数里面写了 yield Async(.....)
apply_async(a.function, a.args, callback = result_queue.put) # 调用这个类的function属性（它是一个函数），
# 并把 args 属性作为参数传入，并把这个函数调用后的返回值放到队列里（原因看 apply_async 的定义）
# 这一段完事后，y = yield Async(add, (2, 3)) 这段代码才正式赋值y
except StopIteration:
break
return wrapper
def add(x, y):
return x + y
@in_lined_async
def test():
y = yield Async(add, (2, 3)) # 在这里会挂住，直到调用apply_async那里才会继续
# 这里 y 之所以不是Async这个类，是因为result_queue.get()那里，于是result_queue就空了
# 这里就会堵塞住，无法继续执行，必须等到下一个值被传入
# 而像 other = yield foo 这样的语句的意思是，“返回 foo 的值，这个值返回给调用者的同时，将 other 的值也设置为那个值”。
# 来源：https://fishc.com.cn/thread-56023-1-1.html
print(y)
y = yield Async(add, ("Hello ", "World"))
print(y)
for n in range(5):
y = yield Async(add, (n, n))
print(y)
print("Goodbye")
test()

复制代码

写的有点乱，见谅

qiuyouzhi · 发表于 2021-2-2 17:07:39

这个代码的主流程应该是in_lined_async..一直没搞明白

Stubborn · 发表于 2021-2-2 22:07:15

qiuyouzhi 发表于 2021-2-2 17:07
这个代码的主流程应该是in_lined_async..一直没搞明白

aa,,待修正

qiuyouzhi · 发表于 2021-2-2 22:13:39

Stubborn 发表于 2021-2-2 22:07
aa,,待修正

蛤？

账号		自动登录	找回密码
密码			立即注册

[已解决]来来，说下这个程序的运行流程

马上注册，结交更多好友，享用更多功能^_^

本帖被以下淘专辑推荐:

浏览过的版块