python 协程

Posted 2020-12-07 乘风去破浪

 1 """
 2 协程，运行的时候轮流去执行各个任务,如果生产者生产的速度比较慢，这里可以使用者个切换出去
 3 
 4 greenlet 会交出执行权，但是如果后面的耗时任务也不会就进入耗时，等下次轮到了，还是要进行耗时
 5 这个程序的效果就只能够是轮询，起不到实际的节约时间的效果
 6 """
 7 import time
 8 from datetime import datetime
 9 from greenlet import greenlet
10 
11 
12 def task1():
13     for i in range(5):
14         print(datetime.now(), ": task1---" + str(i))
15         g2.switch()
16         time.sleep(2)
17 
18 
19 def task2():
20     for i in range(5):
21         print(datetime.now(), ": task2---" + str(i))
22         g3.switch()
23         time.sleep(2)
24 
25 
26 def task3():
27     for i in range(5):
28         print(datetime.now(), ": task3---" + str(i))
29         g1.switch()
30         time.sleep(2)  # 代表耗时任务
31 
32 
33 if __name__ == ‘__main__‘:
34     g1 = greenlet(task1)
35     g2 = greenlet(task2)
36     g3 = greenlet(task3)
37     g1.switch()
38     print("over")

 

 

 

 

 1 """
 2 协程，运行的时候轮流去执行各个任务，如果生产者生产的速度比较慢，这里可以使用者个切换出去
 3 
 4 yield 会交出执行权，但是如果后面的耗时任务也不会就进入耗时，等下次轮到了，还是要进行耗时
 5 这个程序的效果就只能够是轮询，起不到实际的节约时间的效果
 6 """
 7 import time
 8 from datetime import datetime
 9 
10 
11 def task1():
12     for i in range(5):
13         print(datetime.now(), ": task1---" + str(i))
14         yield
15         time.sleep(2)
16 
17 def task2():
18     for i in range(5):
19         print(datetime.now(), ": task2---" + str(i))
20         yield
21         time.sleep(2)
22 
23 def task3():
24     for i in range(5):
25         print(datetime.now(), ": task3---" + str(i))
26         yield
27         time.sleep(2)  # 代表耗时任务
28 
29 
30 
31 if __name__ == ‘__main__‘:
32     g1 = task1()
33     g2 = task2()
34     g3 = task3()
35     while True:
36         try:
37             next(g1)
38             next(g2)
39             next(g3)
40         except:
41             break
42     print("over")