天行健,君子以自强不息!
发布时间:2014-12-16 22:14:18
threading.Thread 并没有显式的提供获取线程调用函数返回值的方法,需求自己实现。使用数据库是一个办法: 可以让子线程将数据写到数据库中,消费线程再去数据库中读取数据;如果不想用数据库,可以使用类的全局变量来做传递,示例代码如下:import osimport threadingclass SubThread(): data = {}&n.........【阅读全文】
发布时间:2014-12-16 22:07:36
前言刚开始使用用tornado时都很迷惑:tornado不是标榜异步非阻塞解决10K问题的嘛?但为什么我在handler中有一个步骤是耗时时,整体的响应就慢下了呢?是不是torando根本就不好用。其实是你用错了,因为你没有将你的耗时任务使用tornado的异步功能实现。下面就各种torndo响应请求,进行耗时任务处理时的各种异步场景.........【阅读全文】
发布时间:2014-12-15 23:09:20
三、tornado结合RabbitMQ实现异步任务处理3.1 安装环境1. 安装tornado见文章《CentOS6.4安装python2.7.3环境和Tornado》2. 安装 tornoda-celerytornado-celery的安装很简单:$ pip install tornado-celeryDownloading/unpacking tornado-celery Downloading tornado-celery-0.3.4.tar.gz Runnin.........【阅读全文】
发布时间:2014-12-09 17:54:12
三、异步client与异步server的通信1. 服务端代码pythone socket的server段,开放三个端口:10000,10001,10002.例子中是每个server绑定一个端口,测试的时候需要分别开3个shell,分别运行.这太麻烦了,就分别用三个Thread来运行这些services#!/usr/bin/env python## -*- coding:utf-8 -*-# File: multithrd_socket_.........【阅读全文】
发布时间:2014-12-09 17:46:07
异步网络能极大地提高程序的并行处理能力,所以写了一个专题来总结python中的异步通信。一、同步client与同步server的通信1.1. 《python的socket通信实例》中的例子1. TCP server端代码#!/usr/bin/env python## -*- coding:utf-8 -*-# File: sync_socket_server.py#from socket import *from time import c.........【阅读全文】