—python异步处理—
1,第一类面向切面
AsyncMixin:异步处理基类,包含queue和thread元组
async_thread:异步method处理类,将方法加入到AsyncMixin的queue中
async_class:异步class包装类,对class指定的异步method元组,放入到async_thread
2,第二类继承
WorkerThread:继续thread类,在WorkerThread中定义一个queue,将异步的处理业务加入到queue中即可
—mysql封装类—
1,WorkerThread
实际的一个run线程继续Thread,在run方法里异步调用mysql类进行数据库处理(MysqlThread)
2,MysqlThread
继承WorkerThread,根据dbconfig创建mysql实例
3,AsyncMysql
AsyncMysql异步myslq继承AsyncMixin,并注解async_class,主要是获取拼装的sql。pool=self
4,mysql 被WorkerThread里包含,在WorkerThread的run方法里异步调用
—启动—
1,tornado主线程启动 tornado.ioloop.IOLoop.instance().start()
在WorkerThread执行完业务后,如果业务传的有callback,则执行self._pool._ioloop.add_callback(partial(callback, result,ex))
服务器托管,北京服务器托管,服务器租用 http://www.fwqtg.net
机房租用,北京机房租用,IDC机房托管, http://www.e1idc.net