import greenlet
"greenlet可进行手动切换"def test1():print(12)gr2.switch() # 启动gr2print(34)gr2.switch() # 切换回gr2def test2():print(56)gr1.switch() # 切换gr1print(78)gr1 = greenlet.greenlet(test1)  # 启动一个协程
gr2 = greenlet.greenlet(test2)
gr1.switch() # 启动/切换

import geventdef func1():print('\033[31;1m李闯在跟海涛搞...\033[0m')gevent.sleep(0)print('\033[31;1m李闯又回去跟继续跟海涛搞...\033[0m')def func2():print('\033[32;1m李闯切换到了跟海龙搞...\033[0m')gevent.sleep(0)print('\033[32;1m李闯搞完了海涛，回来继续跟海龙搞...\033[0m')def func3():print("你好，切换到了func3")gevent.sleep(0)print("func3执行完毕")def func4():print("切换到func4")gevent.sleep(0)print("func4执行完毕")gevent.joinall([gevent.spawn(func1), # 发起一个协程
    gevent.spawn(func2),gevent.spawn(func3),gevent.spawn(func4)
])

from gevent import monkey;monkey.patch_all()
"Python中的分号表示分隔，两条语句出现在同一行时必须要加分号"
import gevent
from urllib.request import urlopen
import timedef fcun(url):print('GET: %s' % url)resp = urlopen(url)data = resp.read()print('%d bytes received from %s.' % (len(data), url))a=["https://www.python.org/","https://www.yahoo.com/","https://github.com/"]
start_time = time.time()
# for i in a:
#     fcun(i)

gevent.joinall([gevent.spawn(fcun, 'https://www.python.org/'),gevent.spawn(fcun, 'https://www.yahoo.com/'),gevent.spawn(fcun, 'https://github.com/'),
])end_time = time.time()
print("用时：",end_time-start_time)'''
经过测试运行时间发现，多协程的执行效率要比串行执行要快很多
'''

import gevent
from gevent.event import Eventevt = Event()def setter():print 'Wait for me'gevent.sleep(3)  # 3秒后唤醒所有在evt上等待的协程print "Ok, I'm done"evt.set()  # 唤醒def waiter():print "I'll wait for you"evt.wait()  # 等待print 'Finish waiting'gevent.joinall([gevent.spawn(setter),gevent.spawn(waiter),gevent.spawn(waiter),gevent.spawn(waiter),gevent.spawn(waiter),gevent.spawn(waiter)
])

from gevent.event import AsyncResult
aevt = AsyncResult()def setter():print 'Wait for me'gevent.sleep(3)  # 3秒后唤醒所有在evt上等待的协程print "Ok, I'm done"aevt.set('Hello!')  # 唤醒，并传递消息def waiter():print("I'll wait for you")message = aevt.get()  # 等待，并在唤醒时获取消息print 'Got wake up message: %s' % message

import gevent
from gevent.queue import Queueproducts = Queue()def consumer(name):#while not products.empty():while True:try:print('%s got product %s' % (name, products.get_nowait()))gevent.sleep(0)except gevent.queue.Empty:breakprint('Quit')def producer():for i in range(1, 10):products.put(i)gevent.joinall([gevent.spawn(producer),gevent.spawn(consumer, 'steve'),gevent.spawn(consumer, 'john'),gevent.spawn(consumer, 'nancy'),
])

import gevent
from gevent.coros import BoundedSemaphoresem = BoundedSemaphore(2)def worker(n):sem.acquire()print('Worker %i acquired semaphore' % n)gevent.sleep(0)sem.release()print('Worker %i released semaphore' % n)gevent.joinall([gevent.spawn(worker, i) for i in xrange(0, 6)])

Worker 0 acquired semaphore
Worker 1 acquired semaphore
Worker 0 released semaphore
Worker 1 released semaphore
Worker 2 acquired semaphore
Worker 3 acquired semaphore
Worker 2 released semaphore
Worker 3 released semaphore
Worker 4 acquired semaphore
Worker 4 released semaphore
Worker 5 acquired semaphore
Worker 5 released semaphore

import gevent
from gevent.local import localdata = local()def f1():data.x = 1print data.xdef f2():try:print data.xexcept AttributeError:print 'x is not visible'gevent.joinall([gevent.spawn(f1),gevent.spawn(f2)
])

import socket
import geventfrom 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 socketHOST = 'localhost'  # The remote host
PORT = 8001         # The same port as used by the server
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
while True:msg = bytes(input(">>:"), encoding="utf8")s.sendall(msg)data = s.recv(1024)# print(data)print('Received', repr(data))  #  repr 格式化输出
s.close()