python网络编程--协程

#基于yield并发执行，多任务之间来回切换，这就是个简单的协程的体现，但是他能够节省I/O时间吗？不能
import time
def consumer():
    ‘‘‘任务1:接收数据,处理数据‘‘‘
    while True:
        x=yield
        # time.sleep(1) #发现什么？只是进行了切换，但是并没有节省I/O时间
        print(‘处理了数据：‘,x)
def producer():
    ‘‘‘任务2:生产数据‘‘‘
    g=consumer()
    next(g)  #找到了consumer函数的yield位置
    for i in range(3):
    # for i in range(10000000):
        g.send(i)  #给yield传值，然后再循环给下一个yield传值，并且多了切换的程序，比直接串行执行还多了一些步骤，导致执行效率反而更低了。
        print(‘发送了数据：‘,i)
start=time.time()
#基于yield保存状态,实现两个任务直接来回切换,即并发的效果
#PS:如果每个任务中都加上打印,那么明显地看到两个任务的打印是你一次我一次,即并发执行的.
producer() #我在当前线程中只执行了这个函数，但是通过这个函数里面的send切换了另外一个任务
stop=time.time()

# 串行执行的方式
# res=producer()
# consumer(res) 
# stop=time.time()

print(stop-start)

import time
def func1():
    while True:
        print(‘func1‘)
        yield

def func2():
    g=func1()
    for i in range(10000000):
        i+1
        next(g)
        time.sleep(3)
        print(‘func2‘)
start=time.time()
func2()
stop=time.time()
print(stop-start)

import time

def f1():
    for i in range(10):
        time.sleep(0.5)
        print(‘f1>>‘,i)
        yield

def f2():
    g = f1()
    for i in range(10):
        time.sleep(0.5)
        print(‘f2>>‘, i)
        next(g)

f1()
f2()

import time
# import greenlet
from greenlet import greenlet

def f1(s):
    print(‘第一次f1‘+s)
    g2.switch(‘taibai‘)  #切换到g2这个对象的任务去执行
    time.sleep(1)
    print(‘第二次f1‘+s)
    g2.switch()

def f2(s):
    print(‘第一次f2‘+s)
    g1.switch()
    time.sleep(1)
    print(‘第二次f2‘+s)

g1 = greenlet(f1)  #实例化一个greenlet对象,并将任务名称作为参数参进去
g2 = greenlet(f2)
g1.switch(‘alex‘) #执行g1对象里面的任务

pip3 install gevent

g1 = gevent.spawn(func,1,2,3,x=4,y=5)　　创建一个协程对象g1,spawn括号内第一个参数是函数名,如eat,后面可以有多个参数,可以是位置实参或关键字实参, 都是传给函数eat的
g2 = gevent.spawn(func2)

g1.join() 　　等待g1结束
g2.join()　　 等待g2结束

或者:上面两步合成一步:
gevent.joinall([g1, g2])

g1.value拿到func1的返回值　

import gevent
from gevent import monkey;monkey.patch_all()
import time
import threading

def f1():
    print(‘第一次f1‘)
    # print(threading.current_thread().getName())
    # gevent.sleep(1)
    time.sleep(2)
    print(‘第二次f1‘)

def f2():
    # print(threading.current_thread().getName())
    print(‘第一次f2‘)
    # gevent.sleep(2)
    time.sleep(2)
    print(‘第二次f2‘)

s = time.time()
g1 = gevent.spawn(f1) #异步提交了f1任务
g2 = gevent.spawn(f2) #异步提交了f2任务
# g1.join()
# g2.join()
gevent.joinall([g1,g2])
e = time.time()
print(‘执行时间:‘,e-s)
print(‘主程序任务‘)

from gevent import monkey;monkey.patch_all() #必须写在最上面，这句话后面的所有阻塞全部能够识别了

import gevent  #直接导入即可
import time
def eat():
    #print()　　
    print(‘eat food 1‘)
    time.sleep(2)  #加上mokey就能够识别到time模块的sleep了
    print(‘eat food 2‘)

def play():
    print(‘play 1‘)
    time.sleep(1)  #来回切换，直到一个I/O的时间结束，这里都是我们个gevent做得，不再是控制不了的操作系统了。
    print(‘play 2‘)

g1=gevent.spawn(eat)
g2=gevent.spawn(play_phone)
gevent.joinall([g1,g2])
print(‘主‘)