我正在使用asyncio在python3.5中编写一个tcp客户端，在阅读了关于高级流应用程序接口的之后，我尝试使用低级protocol应用程序接口来实现。class _ClientProtocol(asyncio.Protocol): self.transportloop=None):
浏览 3提问于2018-02-05得票数 1
回答已采纳
2回答
我使用的是一个asyncio.Protocol服务器，其目的是客户端调用服务器，但在停止客户端循环之前等待服务器响应并返回数据。基于异步doc客户机和服务器：，transport.write的结果(.)被调用时立即返回。n)方法中运行data_received()也没有任何效果。yield from asyncio.sleep(n)和data_received()中的yield from asyncio.async(async
浏览 1提问于2014-09-05得票数 4
回答已采纳
我编写了一个测试程序来尝试使用create_task()，它需要等待创建的任务完成。
我尝试使用loop.run_until_complete()来等待任务完成，但它导致了一个带有回溯的错误。/Users/jason/.virtualenvs/xxx/bin/python3.5 /Users/jason/asyncio/examples/hello_corout
浏览 0提问于2016-03-21得票数 21
回答已采纳
2回答
获取异步服务器以调用另一台服务器
、、、、
Client'
transport.write(self.message.encode())sending message'
transport.write(self.message.encode(self, data):
浏览 2提问于2014-09-03得票数 2
回答已采纳
我试图使用for和asyncio.gather启动一组(一个或多个)辅助程序实例，但没有成功。# -*- coding: utf-8 -*-
import aioserial # Loop Asyncio centrals = utils.auth()
#(*lst_cor
浏览 2提问于2021-06-14得票数 1
回答已采纳
我有一个流应用程序，它几乎连续地将给定的数据作为输入，并使用该值发送HTTP请求，并对返回的值执行一些操作。'): async with session.post(url, data = post_data) as response: res = await asyncio.gather(*[task])()
浏览 1提问于2019-03-05得票数 0
回答已采纳
1回答
Python异步等待线程
、、、
为了测试这个想法，我用Python3.5编写了以下测试脚本：# Testing out Python's() asyncio.ensure_future(sendmsg("hippa1"), loop=loop),
asyncio.ensure_futureloop.run_until_complete(<
浏览 0提问于2016-05-14得票数 5
我试图用python3.5使用异步和关键字等待/异步，我对python中的异步编程相当陌生。我在这方面的大部分经验都是在NodeJS。除了调用我的启动函数来启动程序之外，我似乎做的一切都是正确的。import asyncio
foo = await <retrieve some data> await get_data()
但是
浏览 1提问于2018-04-13得票数 0
回答已采纳
2回答
我尝试以这种方式进行异步API调用：异步def get_data(client，postdata)：res = await client.post(url=_url，headers=_headers，data=postdata)返回res
异步def parse_res(客户端，postdata)：res =等待get_data(客户端，后置数据)如果boolcalls.append(asyncio.create_task(parse_r
浏览 4提问于2022-01-19得票数 2
2回答
我有这样的代码： print('1') print('5')async def part2(): await asyncio.sleep(2)
p2 = await part
浏览 5提问于2020-02-26得票数 0
回答已采纳
2回答
在python > 3.5中，如何让coroutine在由于TimeoutError而被取消后返回最终值？它在python3.5中运行得很好，但最近我尝试升级到3.8，结果遇到了麻烦。我需要保持main作为异步函数，因为在我的实际代码中，它创建了一个aiohttp会话供其他协同器共享，而现代的aiohttp要求在异步contextmanager (而不是常
浏览 1提问于2019-12-11得票数 1
回答已采纳
然而，我把整个代码库SCPed到了一台远程机器上，在那台机器上我发布的事件不能超过15个，否则会出现这个错误：Exception/python3.5/lib/python3.5/asyncio/futures.py", line 332, in set_result
File "/home/bli1/py/python3.5</em
浏览 0提问于2016-11-04得票数 1
如何在异步完成所有任务之前立即获得某人任务的返回？import asyncio print(f"test1print(f"all end at {time.strftime('%X')}")
从上面的代码(python 3.7+)中，我只能在test2和test2都完成之
浏览 2提问于2019-11-23得票数 1
回答已采纳
该程序可以在ubuntu 16.04的python3.5中运行良好，当所有的工作都完成后，它将退出。源代码如下。_run_once() handle._run()
File "/usr/lib/python3.5/as
浏览 14提问于2017-08-06得票数 1
回答已采纳
1回答
如果这些测试中的任何一个失败，父函数应该返回fail。我想用异步异步运行这两个测试，一旦其中一个测试失败，父函数应该返回fail并取消另一个测试。我对异步通信很陌生，我用条件阅读了一些示例，但不知道如何用条件编写异步。
tasks = [ioloop.create_task(test1(data)), ioloop.create_task(test2(d
浏览 1提问于2018-04-08得票数 0
回答已采纳
1回答
如我们所知，在async函数中，在等待的协同线完成执行之前，代码将不会继续执行：# or
await asyncio.gather(coro_1(), coro_2())asyncio.create_task(coro())的事件循环中添加协同值，后者返回。在我的场景中，任务是将添加到>>>现有的运行循环<<<中，接下来的代码将继续执行，而无需等待任务/协同器完成。在朱庇特笔记本中，我们不能调用<
浏览 1提问于2020-05-01得票数 0
回答已采纳
1回答
结合两个基于异步的代码段
、、、、
高速公路部分工作得很好，就像这样：from asyncio import sleep print('Data received: {!"，第400行，在as_future返回create_future_error(create_failure())文件"/usr/lib/pyth
浏览 0提问于2018-04-11得票数 1
据我所知，从协程中的协程中得到的让步会将线程控制传递给事件循环。这与将协程包装在ansyncio.wait_for调用中并从后一个调用中让步有什么不同？
浏览 1提问于2017-07-21得票数 10
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
对象存储
云直播活动推荐
腾讯云开发者
