from greenlet import greenletdef eat(name):print('%s eat 1'%name)g2.switch('egon')print('%s eat 2'%name)g2.switch()
def play(name):print('%s play 1' %name)g1.switchprint('%s play 2' %name)g1 = greenlet(eat)
g2 = greenlet(play)g1.switch('egon')#可以在第一次switch时传入参数,以后都不需要

import gevent
def eat(name):print('%s eat 1' %name)gevent.sleep(2)print('%s eat 2' %name)def play(name):print('%s play 1' %name)gevent.sleep(1)print('%s play 2' %name)g1=gevent.spawn(eat,'egon')
g2=gevent.spawn(play,name='egon')
g1.join()
g2.join()
#或者gevent.joinall([g1,g2])
print('主')

import socket
import requests# 方式一
ret = requests.get('https://www.baidu.com/s?wd=alex')# 方式二
client = socket.socket()# 百度创建连接: 阻塞
client.connect(('www.baidu.com',80))# 问百度我要什么？
client.sendall(b'GET /s?wd=alex HTTP/1.0\r\nhost:www.baidu.com\r\n\r\n')# 我等着接收百度给我的回复
chunk_list = []
while True:chunk = client.recv(8096)if not chunk:breakchunk_list.append(chunk)body = b''.join(chunk_list)
print(body.decode('utf-8'))

import socket
import requests# 方式一
key_list = ['alex','db','sb']
for item in key_list:ret = requests.get('https://www.baidu.com/s?wd=%s' %item)# 方式二
def get_data(key):# 方式二client = socket.socket()# 百度创建连接: 阻塞client.connect(('www.baidu.com',80))# 问百度我要什么？client.sendall(b'GET /s?wd=alex HTTP/1.0\r\nhost:www.baidu.com\r\n\r\n')# 我等着接收百度给我的回复chunk_list = []while True:chunk = client.recv(8096)if not chunk:breakchunk_list.append(chunk)body = b''.join(chunk_list)print(body.decode('utf-8'))key_list = ['alex','db','sb']
for item in key_list:get_data(item)

import threadingkey_list = ['alex','db','sb']
for item in key_list:t = threading.Thread(target=get_data,args=(item,))t.start()

import socket
import selectclient1 = socket.socket()
client1.setblocking(False) # 百度创建连接: 非阻塞try:client1.connect(('www.baidu.com',80))
except BlockingIOError as e:passclient2 = socket.socket()
client2.setblocking(False) # 百度创建连接: 非阻塞
try:client2.connect(('www.sogou.com',80))
except BlockingIOError as e:passclient3 = socket.socket()
client3.setblocking(False) # 百度创建连接: 非阻塞
try:client3.connect(('www.oldboyedu.com',80))
except BlockingIOError as e:passsocket_list = [client1,client2,client3]
conn_list = [client1,client2,client3]while True:rlist,wlist,elist = select.select(socket_list,conn_list,[],0.005)# wlist中表示已经连接成功的socket对象for sk in wlist:if sk == client1:sk.sendall(b'GET /s?wd=alex HTTP/1.0\r\nhost:www.baidu.com\r\n\r\n')elif sk==client2:sk.sendall(b'GET /web?query=fdf HTTP/1.0\r\nhost:www.sogou.com\r\n\r\n')else:sk.sendall(b'GET /s?wd=alex HTTP/1.0\r\nhost:www.oldboyedu.com\r\n\r\n')conn_list.remove(sk)for sk in rlist:chunk_list = []while True:try:chunk = sk.recv(8096)if not chunk:breakchunk_list.append(chunk)except BlockingIOError as e:breakbody = b''.join(chunk_list)# print(body.decode('utf-8'))print('------------>',body)sk.close()socket_list.remove(sk)if not socket_list:break