论坛 › Python交流 › 来来，说下这个程序的运行流程

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

来来，说下这个程序的运行流程

本帖最后由 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()

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

@Twilight6如果Twilight6帮助到了我，我会给你一个最佳的{:10_254:}

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

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

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

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

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

同感{:10_266:}

老八秘制 发表于 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
不是你的问题，我也报错了，但是我看不懂代码...

{:10_250:}
我表示还行

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
快去音频问题那领鱼币 哈哈

{:10_256:}感谢

永恒的蓝色梦想 发表于 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
不是你的问题，我也报错了，但是我看不懂代码...

不好意思哈，参数收集出了点问题，代码已经修正！{:10_254:}{:10_245:}

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()
写的有点乱，见谅

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,,待修正

蛤？

查看完整版本: 来来，说下这个程序的运行流程