問題出如今循環體內的回調函數,用一個很簡單的例子舉例:javascript
for x in xrange(3): print "requests begin:%s"%x def callback(respon): print x print respon.body client.fetch("http://httpbin.org/get?x=%s" % x, callback)
此例子忽略了等待回調函數完成的wait實現(不實現這個會致使做爲單個文件運行的時候,還沒得到結果就退出了),在tornado.testing中的AsyncTestCase提供了相關功能
httpbin.org/get這個地址的做用是返回了請求的json對象,形如:java
{ "args": { "x": "0" }, "headers": { "Accept-Encoding": "gzip", "Connection": "close", "Host": "httpbin.org", "X-Request-Id": "95df3c15-7ed0-4a6d-830d-fb9629e66515" }, "origin": "192.81.129.91", "url": "http://httpbin.org/get?x=0" }
但實際上,因爲回調函數特殊的特性:訪問閉包內局部變量的當前值。易知,在第一個請求
http://httpbin.org/get?x=0的url返回時,循環早已結束,此時的x已經爲2,所以實際上雖然httpbin.org返回的json告訴咱們,get參數裏的x爲0,但閉包內訪問到的x已是2了python
解決方法我想了兩個,一個是利用回調函數構造時的變量空間,在構造函數時即產生這個參數,形如:json
client = AsyncHTTPClient(self.io_loop) for x in xrange(3): def callback(respon,num=x): print x, num print respon.body if num == 2: self.stop() client.fetch("http://httpbin.org/get?x=%s" % x, wrap(x))
一種是再包一層閉包(這層閉包也能夠放在for外面):閉包
client = AsyncHTTPClient(self.io_loop) for x in xrange(3): def wrap(number): num = number def callback(respon): print x, num print respon.body if num == 2: self.stop() return callback client.fetch("http://httpbin.org/get?x=%s" % x, wrap(x)) #wrap放在for外面: client = AsyncHTTPClient(self.io_loop) def wrap(number): num = number def callback(respon): print x, num print respon.body if num == 2: self.stop() return callback for x in xrange(3): client.fetch("http://httpbin.org/get?x=%s" % x, wrap(x))
思索了一下,閉包的內存佔用問題應當是不可避免的?當循環體的每一項(x)是一個大內存對象時,內存佔用等同於不用迭代器用列表進行循環,除了這兩種不知道還有沒有更優雅的解決方案。。函數