Gevent学习之阻塞与非阻塞.pdf

在线学习好工作 / Gevent 学习之阻塞与非阻塞 gevent 中一个很大的改进就是将阻塞IO 改为非阻塞IO，比如 gevent.socket.patch 就是将项目中阻塞socket 变为非阻塞，因此深刻理解网络IO 部分阻塞／非阻塞十分重要。 1.阻塞调用是指调用结果返回之前，当前线程会被挂起。函数只有在得到结 果之后才会返回 1）connect 阻塞 2 ）接收数据阻塞 2.非阻塞指在不能立刻得到结果之前，该函数不会阻塞当前线程，而会立刻 返回 1）接收数据非阻塞 2 ）非阻塞面临的问题 源码 1.代码示例 import logging import time import errno logging.basicConfig( level=logging.DEBUG , format=%( name ) s : % ( message ) s , ) if __name__ == __main__: import socket ip = localhost port = 58562 logger = logging.getLogger ( client ) # Connect to the server logger.debug( creating socket ) s = socket.socket ( socket.AF_INET, socket.SOCK_STREAM ) logger.debug( connecting to server ) s.setblocking(0) try: s.connect( ( ip , port ) ) except socket.error , msg : if msg[0] != errno.EINPROGRESS : logger.debug( error ) exit(1) #time.sleep(1) # Send the data message = Hello , world #len_sent = s.send ( message ) logger.debug( sending data: %s, message ) while True : try: len_sent = s.send ( message ) break except socket.error, msg : if msg[0] != errno.EAGAIN: exit(1) # Receive a response logger.debug( waiting for response ) while True: try: response = s.recv( len_sent ) break except socket.error, msg: if msg[0] != errno.EAGAIN: exit(1) logger.debug( response from server: %s, response ) # Clean up logger.debug( closing socket ) s.close() logger.debug( done ) 执行结果 2.代码示例 import logging import sys import SocketServer import time log