首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

13 | Tornado源码分析:BaseIOStream 对象(下)

hello 大家好 上期我们已经介绍了 tornado.iostream 模块,也整理了核心代码,不知大家是否理解其中的运作原理,本期我们对这部分的源码进行批注并进行总结。 # -*- encoding: utf-8 -*- # !/usr/bin/python """ @File : __init__.py.py @Time : 2020/09/13 15:24 @Author : haishiniu @Software: PyCharm """ import numbers import socket import sys import errno from tornado import ioloop, stack_context from tornado.concurrent import TracebackFuture from tornado.iostream import UnsatisfiableReadError, StreamBufferFullError from tornado.log import app_log, gen_log from tornado.util import errno_from_exception class BaseIOStream(object): def __init__(self, io_loop=None, max_buffer_size=None, read_chunk_size=None, max_write_buffer_size=None): self.io_loop = io_loop or ioloop.IOLoop.current() self.max_buffer_size = max_buffer_size or 104857600 # 每次<fd>.read调用最多读取的字节数 self.read_chunk_size = min(read_chunk_size or 65536,self.max_buffer_size // 2) # 读缓冲区:读缓冲区中的数据分为已经被消费 + 尚未被消费的。 self._read_buffer = bytearray() # 读指针指向第一个尚未被消费的字节。随着缓冲区中的数据被消费,读指针会右移。 # 当读指针大于缓冲区大小时,缓冲区会向右收缩,释放空间。 self._read_buffer_pos = 0 # 读缓冲区的大小(特指未被消费的那部分缓冲区的大小) self._read_buffer_size = 0 # read_bytes()方法的第一个参数 self._read_bytes = None # read callback 当读操作完成之后,会调用该回调函数 self._read_callback = None # read future 当读操作完成时,会将数据或异常信息填充到该对象中; self._read_future = None # 关注的事件 self._state = None # 异步的读取指定数量的字节。 # 如果指定了callback,那么当读取到指定数量的数据之后,会使用数据作为第一个参数调用这个回调函数; # 如果没有指定callback,则返回一个Future对象。 # 本次我们只解析 streaming_callback、partial为 默认值的情况。 def read_bytes(self, num_bytes, callback=None, streaming_callback=None, partial=False): future = self._set_read_callback(callback) assert isinstance(num_bytes, numbers.Integral) self._read_bytes = num_bytes self._read_partial = partial self._streaming_callback = stack_context.wrap(streaming_callback) try: self._try_inline_read() except: if future is not None: future.add_done_callback(lambda f: f.exc

03

02 | Tornado源码全貌:上帝视角看Tornado

正文共:1610 字 8 图 预计阅读时间:5 分钟 本篇主要从宏观的角度来为大家呈现 Tornado 源码的全貌,从上帝视角来感受一下源码的组织结构。 有人说学技术不就是coding,conding,coding ...... 这种学习方式只见树木不见森林,没有宏观的概念,当与别人聊起的时候都是说的各种细节,不能站在更高的角度来认识和思考这们技术,so还是希望大家学习东西的时候可以: 了解背景(这项技术什么背景下提出的)-->整体把握(这项技术是解决什么问题的?有哪些技术亮点?可能带来什么新的问题?)-->写demo运行(可以了解技术架构,代码组成等)-->找自己感兴趣的点研究(一个大项目的源码很多少则几千行多则几万行甚至几十万行)-->工作中使用体会(在读源码)...... 首先,我们感受一下源码的包中有哪些东西(这个是Tornado3.1.1版本):

02
领券