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

Stubborn

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

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

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

Twilight6

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

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

xiaosi4081

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

同感

老八秘制

都说了不要@人

qiuyouzhi

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

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

qiuyouzhi

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

Twilight6

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

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

qiuyouzhi

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

我表示还行

Twilight6

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

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

qiuyouzhi

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

感谢

永恒的蓝色梦想

建议先改错

老八秘制

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

女子口巴

Stubborn

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

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

Stubborn

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

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

Stubborn

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

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

qiuyouzhi

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

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

Stubborn

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

aa,,待修正

qiuyouzhi

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

蛤？