Java循环内的回调函数问题怎么解决
Java循环内的回调函数问题怎么解决
本篇内容介绍了“Java循环内的回调函数问题怎么解决”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
问题出现在循环体内的回调函数,用一个很简单的例子举例:
for x in xrange(3):
1.<p><font size="3"> print "requests begin:%s"%x</font></p>
2.<p><font size="3"> def callback(respon):</font></p>
3.<p><font size="3"> print x</font></p>
4.<p><font size="3"> print respon.body</font></p>
5.<p><font size="3"> client.fetch("http://httpbin.org/get?x=%s" % x, callback)</font></p>
此例子忽略了等待回调函数完成的wait实现(不实现这个会导致作为单个文件运行的时候,还没获得结果就退出了),在tornado.testing中的AsyncTestCase提供了相关功能
httpbin.org/get这个地址的作用是返回了请求的json对象,形如:
{
1.<p><font size="3"> "args": {</font></p>
2.<p><font size="3"> "x": "0"</font></p>
3.<p><font size="3"> },</font></p>
4.<p><font size="3"> "headers": {</font></p>
5.<p><font size="3"> "Accept-Encoding": "gzip",</font></p>
6.<p><font size="3"> "Connection": "close",</font></p>
7.<p><font size="3"> "Host": "httpbin.org",</font></p>
8.<p><font size="3"> "X-Request-Id": "95df3c15-7ed0-4a6d-830d-fb9629e66515"</font></p>
9.<p><font size="3"> },</font></p>
10.<p><font size="3"> "origin": "192.81.129.91",</font></p>
11.<p><font size="3"> "url": "http://httpbin.org/get?x=0"</font></p>
12.<p><font size="3"> }</font></p>
但实际上,由于回调函数特殊的特性:访问闭包内局部变量的当前值。易知,在第一个请求
http://httpbin.org/get?x=0的url返回时,循环早已结束,此时的x已经为2,因此实际上虽然httpbin.org返回的json告诉我们,get参数里的x为0,但闭包内访问到的x已经是2了
解决方法我想了两个,一个是利用回调函数构造时的变量空间,在构造函数时即产生这个参数,形如:
client = AsyncHTTPClient(self.io_loop)
1.<p><font size="3"> for x in xrange(3):</font></p>
2.<p><font size="3"> def callback(respon,num=x):</font></p>
3.<p><font size="3"> print x, num</font></p>
4.<p><font size="3"> print respon.body</font></p>
5.<p><font size="3"> if num == 2:</font></p>
6.<p><font size="3"> self.stop()</font></p>
7.<p><font size="3"> client.fetch("http://httpbin.org/get?x=%s" % x, wrap(x))</font></p>
一种是再包一层闭包(这层闭包也可以放在for外面):
client = AsyncHTTPClient(self.io_loop)
1.<p><font size="3"> for x in xrange(3):</font></p>
2.<p><font size="3"> def wrap(number):</font></p>
3.<p><font size="3"> num = number</font></p>
4.<p><font size="3"> def callback(respon):</font></p>
5.<p><font size="3"> print x, num</font></p>
6.<p><font size="3"> print respon.body</font></p>
7.<p><font size="3"> if num == 2:</font></p>
8.<p><font size="3"> self.stop()</font></p>
9.<p><font size="3"> return callback</font></p>
10.<p><font size="3"> client.fetch("http://httpbin.org/get?x=%s" % x, wrap(x))</font></p>
11.<p><font size="3"> #wrap放在for外面:</font></p>
12.<p><font size="3"> client = AsyncHTTPClient(self.io_loop)</font></p>
13.<p><font size="3"> def wrap(number):</font></p>
14.<p><font size="3"> num = number</font></p>
15.<p><font size="3"> def callback(respon):</font></p>
16.<p><font size="3"> print x, num</font></p>
17.<p><font size="3"> print respon.body</font></p>
18.<p><font size="3"> if num == 2:</font></p>
19.<p><font size="3"> self.stop()</font></p>
20.<p><font size="3"> return callback</font></p>
21.<p><font size="3"> for x in xrange(3):</font></p>
22.<p><font size="3"> client.fetch("http://httpbin.org/get?x=%s" % x, wrap(x))</font></p>
思索了一下,闭包的内存占用问题应当是不可避免的?当循环体的每一项(x)是一个大内存对象时,内存占用等同于不用迭代器用列表进行循环,除了这两种不知道还有没有更优雅的解决方案。
“Java循环内的回调函数问题怎么解决”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注恰卡编程网网站,小编将为大家输出更多高质量的实用文章!