我想确保我了解如何创建微线程和异步方法。我拥有的是一个返回列表的方法。我希望从某个地方调用它，并立即允许进行其他调用。所以我有这个：
future_1 = get_updates_for_user(userKey, aDate)
future_2 = get_updates_for_user(anotherUserKey, aDate)
somelist.extend(future_1)
somelist.extend(future_2)
....
@ndb.tasklet
def get_updates_for_user(userKey, lastSyncDate):
noteQuery = ndb.GqlQuery('SELECT * FROM Comments WHERE ANCESTOR IS :1 AND modifiedDate > :2', userKey, lastSyncDate)
note_list = list()
qit = noteQuery.iter()
while (yield qit.has_next_async()):
note = qit.next()
noteDic = note.to_dict()
note_list.append(noteDic)
raise ndb.Return(note_list)
这段代码是否符合我的预期？也就是说，这两个调用会异步运行吗？我正确使用期货吗？
Edit:经过测试，代码确实产生了预期的结果。我是 Python 新手 - 有哪些方法可以测试方法是否异步运行？
自己验证这些方法是否同时运行是非常困难的——您必须进行大量的日志记录。而且在开发应用程序服务器中，这会更加困难，因为它并没有真正并行运行 RPC。
你的代码看起来不错，它使用yield在正确的地方。
我唯一的建议是命名你的函数get_updates_for_user_async()-- 这与 NDB 本身使用的约定相匹配，并向代码读者提示该函数返回一个 Future 并且应该产生它以获得实际结果。
另一种方法是使用map_async()方法上的Query目的;它会让你写一个回调，其中只包含to_dict() call:
@ndb.tasklet
def get_updates_for_user_async(userKey, lastSyncDate):
noteQuery = ndb.gql('...')
note_list = yield noteQuery.map_async(lambda note: note.to_dict())
raise ndb.Return(note_list)
高级提示：您可以通过删除@ndb.tasklet装饰器并返回 Future 返回的map_async():
def get_updates_for_user_Async(userKey, lastSyncDate):
noteQuery = ndb.gql('...')
return noteQuery.map_async(lambda note: note.to_dict())
这是对仅包含一个生成并立即返回生成的值的异步函数的一般轻微优化。 （如果你没有立即明白这一点，那么你就处于良好的伙伴关系中，并且它存在被未来的维护者破坏的风险，而他也没有这样做。:-)
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
