IO多路复用,数据库mysql

协程：

单线程下由应用程序级别实现的并发，即把本来由操作系统控制的切换+保存状态，在应用程序里实现

协程的切换vs操作系统的切换

优点：

切换速度远快于操作系统

缺点：

一个任务阻塞了，其余的任务都无法执行

Ps：只有遇到IO才切换到其他任务的协程才能提升单线程的执行效率

把耽搁线程的IO降到最低，最大限度的提升单个线程的执行效率

实现方式

From gevent import spawn,monkey;monkey.patch.all()

IO模型：

block io 阻塞io

nonblocking io 非阻塞io

1、对cpu的无效暂用率过高

2、不能及时反馈客户端的信息

1、IO多路复用

服务器：

server = socket(AF_INET, SOCK_STREAM)
server.bind(('127.0.0.1',8080))
server.listen(5)
server.setblocking(False)

data_dic={}
read_list=[server,]
write_list=[]
print('start....')
while True:
    rl,wl,xl=select.select(read_list,write_list,[]) #read_list=[server,conn1,conn2,conn3,conn4]
#select.select是系统调用功能，是操作系统问，当没有秒数的时候会堵塞，当有秒数时会等#到几秒内没有用户访问，就运行下面的内容，然后再返回到这个等待地方
#rl 有数据的列表套接字  里面有一个server 后期有多个conn
    # print('read_list:%s rl:%s wl:%s ' %(len(read_list),len(rl),len(wl))) #rl=[conn1,conn2]
    for sk in rl:
        if sk == server:
            conn,addr=sk.accept()
            read_list.append(conn)
        else:
            # sk.recv(1024)
            # print(sk)
            data=sk.recv(1024)
            write_list.append(sk)
            data_dic[sk]=data#sk套接字，data消息内容

    for sk in wl:
        sk.send(data_dic[sk].upper())
        data_dic.pop(sk)
        write_list.remove(sk)

客户端：

import socket
chile = socket.socket()
chile.connect(("127.0.0.1",8080))

while True:
    msg = input(">>:").strip()
    if len(msg)==0:continue
    chile.send(msg.encode("utf-8"))
    func=chile.recv(1024)
    print(func.decode("utf-8"))