Python协程、IO多路复用的方法

def consumer(name):    print("---&gt;starting eating baozi...")    while True:        new_baozi = yield        print("[%s] is eating baozi %s" % (name, new_baozi))        # time.sleep(1)  def producer():    r = con.__next__()    r = con2.__next__()    n = 0    while n <p>对协程进行一个定义</p><p>1.必须在只有一个单线程里实现并发</p><p>2.修改共享数据不需加锁</p><p>3.用户程序里自己保存多个控制流的上下文栈</p><p>4.一个协程遇到IO操作自动切换到其它协程</p><p>一个协程的小例子手动切换IO操作<br></p><p>greenlet是一个用C实现的协程模块相比与<a style="color:#f60; text-decoration:underline;" href="https://www.php.cn/zt/15730.html" target="_blank">python</a>自带的yield它可以使你在任意函数之间随意切换而不需把这个函数先声明为generator</p><pre class="brush:python;toolbar:false">import greenlet def test1():    print(12)    g2.switch()    print(34)    g2.switch() def test2():    print(56)    g1.switch()    print(78) g1 = greenlet.greenlet(test1)g2 = greenlet.greenlet(test2)g1.switch()

import gevent  def foo():    print("Running in foo")    gevent.sleep(2)    print("Explicit context switch to foo again")  def bar():    print("Explicit context to bar")    gevent.sleep(1)    print("Implicit context switch back to bar")  def func3():    print("running func3")    gevent.sleep(0)    print("running func3 again") gevent.joinall([    gevent.spawn(foo),  # 生成    gevent.spawn(bar),    gevent.spawn(func3),])

import gevent  def task(pid):    gevent.sleep(0.5)    print("Task %s done" % pid)  def synchronous():    for i in range(1,10):        task(i)  def asynchronous():    threads = [gevent.spawn(task, i) for i in range(10)]    gevent.joinall(threads) print("Synchronous:")synchronous() print("Asynchronous:")asynchronous()

from urllib import requestimport geventfrom gevent import monkey  def f(url):    print("GET: %s" % url)    resp = request.urlopen(url)    data = resp.read()    # file = open("url.html", "wb")    # file.write(data)    # file.close()    print("%d bytes received from %s." % (len(data), url))  monkey.patch_all()  # 把当前程序的所有IO操作给我单独的做上标记gevent.joinall([    gevent.spawn(f, "http://www.yitongjia.com"),    gevent.spawn(f, "http://www.jinyuncai.cn"),    gevent.spawn(f, "https://www.guoshipm.com"),])

import sysimport socketimport timeimport gevent  from gevent import socket,monkeymonkey.patch_all()    def server(port):    s = socket.socket()    s.bind(('0.0.0.0', port))    s.listen(500)    while True:        cli, addr = s.accept()        gevent.spawn(handle_request, cli)      def handle_request(conn):    try:        while True:            data = conn.recv(1024)            print("recv:", data)            conn.send(data)            if not data:                conn.shutdown(socket.SHUT_WR)      except Exception as  ex:        print(ex)    finally:        conn.close()if __name__ == '__main__':    server(8001)

import socketimport threading def sock_conn():     client = socket.socket()     client.connect(("localhost",8001))    count = 0    while True:        #msg = input(">>:").strip()        #if len(msg) == 0:continue        client.send( ("hello %s" %count).encode("utf-8"))         data = client.recv(1024)         print("[%s]recv from server:" % threading.get_ident(),data.decode()) #结果        count +=1    client.close()  for i in range(100):    t = threading.Thread(target=sock_conn)    t.start() 并发100个sock连接

import selectimport socketimport sysimport queue server = socket.socket()server.bind(("0.0.0.0", 6666))server.listen(1000) server.setblocking(False)   # 不阻塞 msg_dic = {} inputs = [server, ]outputs = [] while True:    readable, writeable, exceptional = select.select(inputs, outputs, inputs)    print(readable, writeable, exceptional)    for r in readable:        if r is server:     # 代表来了一个新连接            conn, addr = server.accept()            print("来了个新连接", addr)            inputs.append(conn)     # 因为这个新建立的连接还没发数据过来，现在就接收的话程序就报错了            # 所以要想实现这个客户端发数据来时server端能知道，就需要让select再监测这个conn            msg_dic[conn] = queue.Queue()   # 初始化一个队列，后面存要返回客户端的数据        else:            data = r.recv(1024)            print("收到数据", data)            msg_dic[r].put(data)            outputs.append(r)   # 放入返回的连接队列里            # r.send(data)            # print("send end...")    for w in writeable:     # 要返回给客户端的连接列表        data_to_client = msg_dic[w].get()        w.send(data_to_client)      # 返回给客户端的元数据        outputs.remove(w)       # 确保下次循环的时候，writeable不返回已经处理完的连接     for e in exceptional:        if e in outputs:            outputs.remove(e)        inputs.remove(e)        del msg_dic[e]

import socketimport selectors  sel = selectors.DefaultSelector()  def accept(sock, mask):    conn, addr = sock.accept()    print('accepted', conn, 'from', addr)    conn.setblocking(False)    sel.register(conn, selectors.EVENT_READ, read)  def read(conn, mask):    data = conn.recv(1024)    if data:        print('echoing', repr(data), 'to', conn)        conn.send(data)    else:        print('closing', conn)        sel.unregister(conn)        conn.close() sock = socket.socket()sock.bind(("0.0.0.0", 6666))sock.listen(100)sock.setblocking(False)sel.register(sock, selectors.EVENT_READ, accept) while True:    events = sel.select()    for key, mask in events:        callback = key.data        callback(key.fileobj, mask)