一、介绍
1.协程: 微线程，是一种用户态轻量级线程
如图：在执行A函数的时候，可以随时中断，去执行B函数，然后终端继续执行A函数（可以自动切换）
协程
2.
二、使用方法
-
生成器
生成器是一个返回迭代器的函数，只能用于迭代操作，更简单点理解生成器就是一个迭代器。
# -*- coding:utf-8 -*-
def func1():
for i in range(10):
# 返回一个生成器对象
yield i
if __name__ == '__main__':
f = func1()
print(next(f))
print(next(f))
1-1
- yield from用法:主要设计用来向子生成器委派操作任务
# -*- coding:utf-8 -*-
def func1():
for i in range(10):
# 返回一个生成器对象
yield i
def func2(generator):
# yield from必须在函数体中使用
res = yield from generator
print(res)
if __name__ == '__main__':
fs = func1()
# print(next(f))
# print(next(f))
# func2():生成器函数，封装生产器对象
wrap_g = func2(fs)
for w in wrap_g:
print(w)
1-2
- 协程:微线程，是一种用户态轻量级线程
# -*- coding:utf-8 -*-
def func3():
for i in range(1, 11):
print(f"我是客服{i}号")
yield
def func4():
# 由于func3()返回的是一个生成器对象，所以用一个变量接收一下
g = func3()
next(g)
for i in range(1, 10):
print(f"我的工{i}号")
next(g)
if __name__ == '__main__':
func4()
1-3部分图
二、yield生产者消费者模式:
# -*- coding:utf-8 -*-
from time import sleep
def customer():
while True:
sleep(1)
# 接收生产者的消息，并向消费者发送
n = yield
print(f"生产{n}产品")
yield
def producer():
g = customer()
next(g)
for i in range(1, 10):
sleep(1)
# 向消费者发送值
g.send(i)
print(f"消费{i}产品")
next(g)
if __name__ == '__main__':
producer()
生产者、消费者模式
二、yield源码解读:
typedef struct _frame {
/* 变长对象 （运行时大小不确定） */
PyObject_VAR_HEAD
/* 执行环境链上的前一个frame，很多个PyFrameObject连接起来形成执行环境链表 or Null */
struct _frame *f_back;
/* PyCodeObject 对象，这个frame就是这个PyCodeObject对象的上下文环境 */
PyCodeObject *f_code;
/* builtin名字空间 */
PyObject *f_builtins;
/* global名字空间 */
PyObject *f_globals;
/* local名字空间 */
PyObject *f_locals;
/* "运行时栈"的栈底位置 */
PyObject **f_valuestack;
/* "运行时栈"的栈顶位置 */
PyObject **f_stacktop;
/* 计数 */
PyObject *f_trace;
/* 处理帧中引发了异常 异常类型，异常值，异常状态 */
PyObject *f_exc_type, *f_exc_value, *f_exc_traceback;
/* 初始化异常处理的状态 */
PyThreadState *f_tstate;
/* 上一条字节码指令在f_code中的偏移位置 */
int f_lasti;
/* 当前字节码对应的源代码行 */
int f_lineno;
/* 捕捉异常 */
int f_iblock; /* index in f_blockstack */
/* f_iblock在调用PyFrame_New时被初始化为0 */
PyTryBlock f_blockstack[CO_MAXBLOCKS]; /* for try and loop blocks */
/* 动态内存、维护（局部变量+cell对象集合+free对象集合+运行时栈）所需要的空间 */
PyObject *f_localsplus[1];
} PyFrameObject;
