Python异步处理

回调函数是实现异步操作的常用手法

1、callback版本的示例，其中framework调用logic，在完成某些操作或者接收到信号后，用callback返回异步结果

#!/usr/bin/env python2.7

def framework(logic,callback):

        s=logic()

        print "[FX] logic:",s

        print "[FX] do something..."

        for i in xrange(1000000):

                a=i+1

        callback("async:"+s)

def logic():

        s="mylogic"

        return s

def callback(s):

        print s

framework(logic,callback)

2、使用yield改进的blocking style版本：

#!/usr/bin/env python2.7

#-*- coding:utf8 -*-

def framework(logic):

        try:

                it = logic()

                s = next(it)

                print "[FX] logic:",s

                print "[FX] do something"

                f=open("test.txt",'w')

                for i in xrange(1000000000):

                        f.write(str(i)+'\n')

                f.close()

                it.send("async:" + s)

        except StopIteration:

                pass

def logic():

        s = "mylogic"

        r = yield s

        print r

framework(logic)

巴特西

Python异步处理

最新文章

热门文章