- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
在常规回调中调用异步代码的正确方法是什么?这段代码可以工作,但看起来不太漂亮。我不喜欢响应的调用方式:它需要通过所有函数传递调用者地址。如何为处理程序设置超时?
我在评论中提出了问题。
import asyncio
import logging
logger = logging.getLogger('protocol')
async def echo(data):
#external lib emulator
data = b'>'+data
await asyncio.sleep(1)
return data
class Protocol(asyncio.DatagramProtocol):
def connection_made(self, transport):
logger.debug('connection_made called')
self.transport = transport
def respond(self,task):
logger.debug('respond called')
# i want to get data in attrs, not task
resp,caller = task.result()
self.transport.sendto(resp, caller)
async def handler(self,data, caller):
logger.debug('handler called')
# async needed for `await` and `async for` external library such motor, etc
# do some awaits
data = await echo(data)
# simple echo
return (data, caller)
def datagram_received(self, data, addr):
logger.debug('datagram_received called')
# handler selected by data header
handler = self.handler
# how to do run async handler?
loop = asyncio.get_event_loop()
c = handler(data, addr) #coroutine
f = asyncio.ensure_future(c,loop=loop) #attach coroutine to loop
f.add_done_callback(self.respond)
# How to get response here?
# i cant loop.run_until_complete(...) because loop.run_forever() running
#def wakeup():
# pass
#loop.call_soon(wakeup)
# without this call_soon future is not executed in first programm code, but works in test and after refactor
def main(HOST,PORT):
loop = asyncio.get_event_loop()
t = asyncio.Task(loop.create_datagram_endpoint(
Protocol, local_addr=(HOST,PORT)))
transport, server = loop.run_until_complete(t)
sock = transport.get_extra_info('socket')
# socket tuning here
try:
loop.run_forever()
finally:
transport.close()
loop.close()
logging.basicConfig(level=logging.DEBUG)
main('0.0.0.0',10012)
使用netcat测试nc -u 127.0.0.1 10012
最佳答案
您可以使用 asyncio.Queue 将任务放入一个协程中(处理)并在另一个协程中等待它们(响应):
class Protocol(asyncio.DatagramProtocol):
def __init__(self):
self.data_queue = asyncio.Queue(loop=asyncio.get_event_loop())
asyncio.ensure_future(self.respond())
def connection_made(self, transport):
self.transport = transport
def datagram_received(self, data, addr):
asyncio.ensure_future(self.handler(data, addr), loop=asyncio.get_event_loop())
async def respond(self):
while True:
resp, caller = await self.data_queue.get()
self.transport.sendto(resp, caller)
async def handler(self, data, caller):
data = await echo(data)
self.data_queue.put((data, caller))
关于python - 在常规回调中调用异步代码的正确方法是什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40241039/
当给定两个 bool 参数时,^ 运算符执行异或,例如 true ^ true == false true ^ false == true false ^ true == true false ^ f
我需要下载一个文件(例如: https://www.betaseries.com/srt/391160 )所以我在网上找到了不同的方法: def download(String remoteUrl,
可以说,我们正在计算考试成绩的平均值: 起始考试成绩:75、80、92、64、83、99、79 平均值= 572/7 = 81.714 ... 现在给出81.714,如果您不知道初始测试分数,是否可以
我和一个 friend 正在争论线程池中的线程数应该是处理器计数+ 1还是仅仅是处理器计数。 我之所以选择处理器数量,是因为每个处理器可以分配偶数个线程,而他选择处理器数量+ 1是因为他认为这将帮助他
我已经养成了尽可能使用闭包来代替常规方法的习惯,即使我不需要访问自由变量。所以,我将使用这个: def addNumbers = { 左、右 -> 左 + 右 } ..而不是这个: def addNu
我对 Groovy 非常陌生,我正在尝试《Groovy in Action》书中的这个示例。我有这个 fibonacci.groovy 程序,当尝试使用 java 命令运行该程序时,我收到 NoCla
我有 3 个 TextView 。我需要将它们的权重设置为 Light、Regular 和 Condensed。有人可以帮助我了解如何在 Android 中实现这一点吗? 最佳答案 在 TextVie
如果用户启动我的应用程序并最初选择不允许位置服务,我想通过 UIAlertMessage 提示用户重新考虑(“更新”和“不,谢谢。”)。 “不,谢谢。”这将是一个简单的取消,我希望“更新”将它们直接链
如何在 groovy 中显示一个值是真还是假?我使用 Eclipse 作为我的 IDE。 assert 4 * ( 2 + 3 ) - 6 == 14 //integers only 而且我也
我的问题与“多处理器编程的艺术”一书有关。第4章介绍安全/常规/原子寄存器及其实现。 以下是安全多读取器单写 boolean 寄存器的以下实现,该寄存器基于安全单读取器单写 boolean 寄存器,被
使用下面的代码来保存 float 的值 domainInstance.standardScore = params["standardScore"] as float 在这种情况下,我的输入是 17.
使用下面的代码来保存 float 的值 domainInstance.standardScore = params["standardScore"] as float 在这种情况下,我的输入是 17.
在iOS的about部分中,它具有有关设备的大量信息。 我和我可以访问此信息吗? 我想快速获取settings -> General -> About的数据。在iOS中获得相同的价格是否可行? 最佳答
我正在开发Windows服务,它将承载两件事: WCF服务 用于定期作业执行的“常规” Windows服务(使用Quartz.net) 因此,基本上,一个应用程序(可执行)承载这两种服务类型。 这两种
在mysql中,我有一个名为users的表,其中包含系统中的用户列表... id | name | surname | active ____________________________ 1
所以我在 Debian 服务器上设置了一个 MySQL 数据库,并且它在 phpMyAdmin 客户端上运行良好。我目前正在开发一个项目,编写一个 Java 服务器,该服务器能够通过 JDBC 连接使
已关闭。这个问题是 not reproducible or was caused by typos 。目前不接受答案。 这个问题是由拼写错误或无法再重现的问题引起的。虽然类似的问题可能是 on-top
前两天考试了,其中一道题是把@前面的字母换成新的名字 所以在试卷中我们有 array = "toto@yahoo.com","mimi@yahoo.com".soso@yahoo.com"所以我们应该
大家好 如果字符串语法如下,我如何从字符串中获取数字(正数): t_def_type_id_2 t_def_type_id_22 t_def_type_id_334 所以,在第一个字符串中我想得到 1
我正在寻找不会在内核中阻塞的文件描述符类型。我知道我可以使用 fstat(2) 但 fstat 还会给我各种元数据信息(访问时间等),这些信息可能会阻塞任意时间(特别是在网络文件系统上)。 编辑:我正
我是一名优秀的程序员,十分优秀!