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

def consumer(name):
 print("--->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 < 5:
 n += 1
 con.send(n)
 con2.send(n)
 print("33[32;1m[producer]33[0m is making baozi %s" % n)
 
 
if __name__ == '__main__':
 con = consumer("c1")
 con2 = consumer("c2")
 p = producer()

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 request
import gevent
from 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 sys
import socket
import time
import gevent
 
from gevent import socket,monkey
monkey.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 socket
import 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 select
import socket
import sys
import 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 socket
import 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)