from twisted.web.client import getPage, defer from twisted.internet import reactor def callback(contents): print(contents) url_list = ['http://www.bing.com', 'http://www.baidu.com', ] for url in url_list: deferred = getPage(bytes(url, encoding='utf8')) deferred.addCallback(callback) reactor.run()
事件执行只有开始没有结束,所以须要规定某个目标任务的完成来终止事件react
from twisted.web.client import getPage, defer from twisted.internet import reactor def callback(contents): print(contents) url_list = ['http://www.bing.com', 'http://www.baidu.com', ] _active = [] for url in url_list: d = getPage(bytes(url, encoding='utf8')) d.addCallback(callback) _active.append(d) def all_done(arg): reactor.stop() xx = defer.DeferredList(_active) xx.addBoth(all_done) reactor.run()
将defer对象加入一个列表_active中以此来用defer方法DeferredList来监听该列表中的任务是否完成回调,在执行回调以后addBoth(表示不管错误仍是成功都会执行该方法设置的函数)web