stackless + twisted

# -*- encoding: utf-8 -*-

"""
通过tasklet构造的对象只是加入调度队列，必须等待schedule,
真正执行队列即执行可以通过四个方法：stackless.run(), stackless.schedule()，channel.send(), channel.receive()
任何新建的tasklet必须等待schedule方法来调度，否则无法执行。
"""

import stackless,twisted
from twisted.internet import reactor
from twisted.web import client

class MyTasklet():

    def result(self, content):
        print "html result-----" + content[0:20]
        self.mychannel.send(content)

    def resultError(self, content):
        print "html result error-----" + str(content)
        self.mychannel.send(content)

    def tasklet(self):
        print('MyTasklet.tasklet...', stackless.getcurrent())
        self.mychannel = stackless.channel()
        self._tasklet = stackless.getcurrent()
        self._tasklet._owner = self
        self.handle()

    def handle(self):
        print('MyTasklet.handle')
        content = ''
        try:
            content = self.reqPage()
        except Exception, e:
            print('Exception', e.message)
        print('html content', content[:20]) # 异步返回之后可以继续干别的事情

    def reqPage(self):
        deferred =client.getPage("http://blog.csdn.net")
        deferred.addCallback(self.result)
        deferred.addErrback(self.resultError)
        return self.mychannel.receive() # 当前tasklet 阻塞，不影响其它tasklet运行

from twisted.web import server, resource
from twisted.internet import reactor

# 创建一个简单的web server，接收请求
class Simple(resource.Resource):
    isLeaf=True
    def render_GET(self, request):
        startTasklet() # 接收到请求之后，创建tasklet，进入stackless的世界
        return "Hello, world!"
reactor.listenTCP(8080, server.Site(Simple()))

def startTasklet():
    print 'startTasklet...............'
    mytask = MyTasklet()
    stackless.tasklet(mytask.tasklet)() # 创建tasklet
    tasklet = stackless.schedule() # 启动调度
    print('startTasklet.tasklet', tasklet)

reactor.run() # 启动reactor mainloop

# 如果前面有tasklet，可以将reactor.run()换成下面两句
# stackless.tasklet(reactor.run)()
# stackless.run()

高并发情况下需要做一定处理

原文链接