python-fdt/class02-advanced/code10_coroutine.py at main · PeterLu798/python-fdt · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
from greenlet import greenlet
import gevent, time
from gevent import monkey

# def process():
#     print(f"save user")
#     # 切换到g2协程中执行process2
#     g2.switch("pdf", "word")
#     print(f"save order")
#
#
# def process2(a, b):
#     print(f"read {a}")
#     print(f"read {b}")
#     # 执行完process2后继续切回g1执行process
#     g1.switch()
#
#
# g1 = greenlet(process)
# g2 = greenlet(process2)
#
# # 先执行g1
# g1.switch()


# def funa(n):
#     for i in range(n):
#         print(gevent.getcurrent(), i)
#         # sleep用来模拟一个耗时操作，注意要用gevent的sleep
#         gevent.sleep(1)
#
#
# g3 = gevent.spawn(funa, 2)
# g4 = gevent.spawn(funa, 2)
# g5 = gevent.spawn(funa, 2)
#
# g3.join()

"""
********patch_all演示开始**************
"""
# monkey.patch_all()
#
#
# def funa(n):
#     for i in range(n):
#         print(gevent.getcurrent(), i)
#         # 因为前面申明了monkey.patch_all()，所以这里的time.sleep方法被自动替换成了gevent下非阻塞的同名实现函数
#         time.sleep(1)
#
#
# g3 = gevent.spawn(funa, 2)
# g4 = gevent.spawn(funa, 2)
# g5 = gevent.spawn(funa, 2)
#
# g3.join()
# print("这句话啥时候执行")
"""
********patch_all演示开始**************
"""
"""
********joinall演示开始**************
"""


def func1():
    print('func1开始运行！')
    gevent.sleep(0.3)
    print('func1继续运行。')


def func2():
    print('func2开始运行！')
    gevent.sleep(0.2)
    print('func2继续运行。')


def func3():
    print('func3开始运行！')
    gevent.sleep(0.1)
    print('func3继续运行。')


gevent.joinall((
    gevent.spawn(func1),
    gevent.spawn(func2),
    gevent.spawn(func3),
))
"""
********joinall演示结束**************
"""