协程:gevent模块,遇到i/o自动切换任务 038

Posted 2021-01-16 f-g-f

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了协程:gevent模块,遇到i/o自动切换任务 038相关的知识，希望对你有一定的参考价值。

协程 : gevent模块,遇到io自动切换任务

from gevent import monkey;monkey.patch_all()  # 写在最上面 这样后面的所有阻塞就全部能够识别了
import gevent  # 直接导入即可
from threading import current_thread
import time
def eat(name):
    print(‘%seat1‘% name)
    # gevent.sleep(2)
    time.sleep(2)   # 加上monkey就能
    print(‘%seat2‘% name)
    print(current_thread().getName())
def play(name):
    print(‘%splay1‘% name)
    # gevent.sleep(2)
    time.sleep(2)
    print(‘%splay2‘% name)
    print(current_thread().getName())
g1 = gevent.spawn(eat,‘egon‘)  # 创建一个协程对象 spawn括号内第一个参数是函数名
g2 = gevent.spawn(play,‘egon‘)
gevent.joinall([g1,g2]) # 将g1.join()和g2.join()合成一步写了出来
print(‘主‘)
# 结果为
# egoneat1
# egonplay1
# egoneat2
# DummyThread-1  # 假线程 虚拟线程 其实都在一个线程里面 
# egonplay2
# DummyThread-2
# 主

　　　　gevent.sleep(2)模拟的是gevent可以识别的io阻塞,

　　　　而 time.sleep(2)或其他阻塞是不能直接识别的需要用下面一行代码打补丁就可以识别了

　　　　from gevent import monkey;monkey.patch_all() 放在time, socket之前或者直接将其放在文件开头.

　　　　协程是通过自己的程序实现切换自己能够控制只有遇到协程模块能够识别io操作的时候, 程序才会进行任务切换实现并发效果 , 如果所有的程序都没有io操作那么久基本属于串行执行了.

给大家看一个线程下(协程)来实现多个客户聊天

io多路复用:模型(解决问题方案)

#服务端
from socket import *
import select
server  = socket(AF_INET, SOCK_STREAM)
server.bind((‘127.0.0.1‘,8093))
server.listen(5)
# 设置为非阻塞
server.setblocking(False)
# 将初始化服务端socket对象加入监听列表 后面还要动态添加一些conn连接对象, 当accept的时候sk就有感应 , 当recv的时候conn就有动静
rlist = [server,]
rdata = {}  # 存放客户端发送过来的消息
wlist = []  # 等待写对象
wdata = {}  # 存放要返回客户端的消息
print(‘准备监听!‘)
count = 0 # 写着计数用的 为了看实验效果用的 , 没用
while 1:
    # 开始select监听,对rlist中服务端server进行监听 , select函数阻塞进程 , 直到rlist中套接字被触发(在此例中,套接字接收到客户端发来的握手信号 , 从而变得可读 满足select函数的可读条件),被触发的(有动静的)套接字(服务器套接字)返回给了rl这个返回值里面;
    rl,wl,xl = select.select(rlist,wlist,[],0.5)
    print(‘%s 次数>>‘%(count),wl)
    count = count + 1
    # 对rl进行循环判断是否有客户端连接进来 , 当有客户端连接进来时select将触发
    for sock in rl:
        # 判断当前触发的是不是socket对象, 当触发的对象是socket对象时说明有新客户端accept连接进来了
        if sock == server:
            # 接收客户端的连接, 获取客户端对象和客户端地址信息
            conn,addr = sock.accept()
            # 把新的客户端连接加入到监听列表中 当客户端连接有接受消息的时候 , select将会被触发 ,会知道这个链接有动静 , 有消息 , 那么返回geirl这个返回值列表里面
            rlist.append(conn)
        else:
            # 由于客户端连接进来时socket接收客户端请求 , 将客户端连接加入到了监听列表中(rlist),客户端发送消息的时候这个链接将触发
            # 所以判断是否是客户端连接对象触发
            try:
                data = sock.recv(1024)
                # 没有数据的时候,将这个连接关闭掉 , 并从监听列表中移除
                if not data:
                    sock.close()
                    rlist.remove(sock)
                    continue
                print(‘received{0} from client{1}‘.format(data.decode(),sock))
                # 将接收到的客户端的消息保存下来
                rdata[sock] = data.decode()
                # 将客户端连接对象和这个对象接受到的消息加工成返回消息 , 并添加到wdata这个字典里面
                wdata[sock] = data.upper()
                # 要给这个客户端回复消息的时候, 我们将这个链接添加到wlist监听列表中
                wlist.append(sock)
            # 如果这个连接出错了,客户端暴力断开了(注意 , 还没有接收到客户端的消息 , 或者接收消息的过程中出错了)
            except Exception:
                # 关闭这个连接
                sock.close()
                # 在监听列表中将他删除 , 因为不管什么原因 毕竟是断开了 没必要再监听他了
                rlist.remove(sock)
    # 如果现在没有客户端请求连接 也没有客户端发送消息时 , 开始对发送消息的列表进行处理 , 是否需要发送消息
    for sock in wl:
        sock.send(wdata[sock])
        wlist.remove(sock)
        wdata.pop(sock)
    # 将以此select监听列表中有接收数据的conn对象所接收到的消息打印一下
    # for k , v in rdata.items():
    #       print(k,‘发来的消息是‘,v)
    # # 清空接收到的消息
    #rdata.clear()