不久前，我从David Beazley的协程程序上读到了，我想知道是否有实际的基于Python的软件使用它们？
为什么协程看起来像是Python中最未使用的功能？
浏览 0提问于2011-04-23得票数 8
1回答
我通过lua脚本从浏览器执行python脚本：
os.execute('python scriptname.py --arg1 Test --arg2 Test2')
我再次这样做(例如，通过刷新页面，发送表单)
os.execute('python scriptname.py --arg1 Test3 --arg2 Test4')
我希望第二个脚本只被执行时，第一个脚本完成到最后。我希望脚本被添加到队列中，并从最旧的脚本到最新的脚本执行。我该怎么做呢？
浏览 2提问于2018-07-08得票数 0
2回答
我有一个关于协程实现的问题。我首先在Lua和stackless-python上看到了coroutine。我可以理解它的概念，以及如何使用yield关键字，但我不知道它是如何实现的。
我能得到一些关于它们的解释吗？
浏览 2提问于2010-08-09得票数 4
回答已采纳
1回答
我对Python和ECMAScript中的生成器的理解是，它们比普通生成器更强大。例如，它们都允许通过next()将值传递回生成器，并且都允许从另一个生成器(Python中的yield from和ES6中的yield * )生成，这是生成器中不需要的两件事。
那么，考虑到这种扩展的功能，在Python和ES6中实现的生成器是否与协程相同？有什么不同吗？
浏览 0提问于2015-08-08得票数 1
2回答
我已经看到很多关于python中的协程的演讲和文章。它们被认为是“微线程”，我听说它们可以提高性能。
协程如何提高性能？到目前为止，我看到的是它们是单线程的，并且是按顺序执行的。我同意从设计的角度来看，它们非常优雅，特别是在生产者/消费者类型的应用程序中。
我想我没有抓住要点。有人能帮我解释一下吗？
浏览 0提问于2011-07-05得票数 16
回答已采纳
从文档中我有这个例子，我已经测试过了，并且工作正常。
from requests_html import AsyncHTMLSession
asession = AsyncHTMLSession()
async def get_pythonorg():
r = await asession.get('https://python.org/')
async def get_reddit():
r = await asession.get('https://reddit.com/')
async def get_google():
r
浏览 5提问于2021-05-23得票数 1
我目前正在尝试用Python学习asyncio。我知道await关键字告诉循环它可以切换协程。但是，我应该在什么时候实际使用它呢？为什么不把它放在第一位呢？
另外，为什么await在'response.text()‘之前，为什么不在session.get(url)之前？
async def print_preview(url):
# connect to the server
async with aiohttp.ClientSession() as session:
# create get request
async with ses
浏览 0提问于2020-05-15得票数 0
我已经创建了一个hangman命令，但在调用该命令时出现错误，如第二段代码所示。有没有人知道这个错误指的是什么，或者我当前代码中的错误？
@bot.command()
async def hangman(self, ctx):
"""Play hangman!"""
game = Hangman(ctx, self.bot)
await game.play()
Ignoring exception in command play:
Traceback (most recent cal
浏览 1提问于2021-01-26得票数 2
我正在尝试为我的异步循环设置一个标志。我试着使用asyncio.Event，但得到了一个RuntimeError，下面是我的代码： import sys
import asyncio
import logging
root = logging.getLogger()
root.setLevel(logging.DEBUG)
ch = logging.StreamHandler(sys.stdout)
ch.setFormatter(
logging.Formatter('%(asctime)s - %(name)s - %(levelname)s %(message)s&
浏览 54提问于2020-12-18得票数 0
我正在使用Python和Tornado来构建带有jquery UI滑块元素的基本应用程序。我的目标是，当用户与滑块交互时，它将被发送一个值给python函数，结果将显示在python控制台中。我的custom.js是：
$(function() {
$("#slider-range-max").slider({
min : 0,
max : 100,
slide : function(event, ui) {
$("#amount").val(ui.value);
ajax({
浏览 2提问于2016-05-16得票数 4
1回答
我想返回异步生成器的第一个元素，并处理剩余的值，而不返回像fire和forget那样的值。如何在python中提前返回协程？在将迭代器传递给asyncio.create_task之后，它不会打印剩余值。
import asyncio
import time
async def async_iter(num):
for i in range(num):
await asyncio.sleep(0.5)
yield i
async def handle_remains(it):
async for i in it:
print(
浏览 2提问于2021-09-27得票数 0
我知道在python37中我们有一个新的接口asyncio.get_running_loop()，它很容易使用，让我们在调用协程时不需要显式地传递eventloop。 我想知道是否有什么方法可以让我们在python36中获得同样的效果？ # which allows us coding conveniently with this api:
import asyncio
async def test():
print("hello world !")
async def main():
loop = asyncio.get_running_loop()
浏览 33提问于2019-06-25得票数 4
回答已采纳
4回答
对于对其他语言(Python/JavaScript)有一定异步经验的人来说，当谈论异步/等待时，总是会假设在某个地方有一个事件循环。但是对于C++，我已经浏览了文档，没有找到任何讨论事件循环的地方。为什么会这样呢？
对于Node，它只有一个默认的事件循环。对于Python，如果需要，您可以创建多个。但是对于C++，这个事件循环是不是和Node一样呢？或者出于某种原因，我们根本不需要它吗？
浏览 7提问于2021-02-20得票数 19
1回答
我尝试使用Python进行异步编程，遇到了一个有趣的应用程序，我需要在大约100台机器上收集大约10个文件的文件大小，以查看哪些机器没有适当地清除它们的日志文件。
我的同步方法是：
File_info = namedtuple("File_info", "machineinfo size")
machines = utils.list_machines() # the computers being queried
# each machine object has attributes like "name", "IP",
浏览 1提问于2017-04-14得票数 0
1回答
如何从异步函数返回值
、、、、
我有一个异步函数，我试图从其中获取返回变量，但由于某种原因，我无法让它工作，我尝试了几个与googling不同的方法，但它们都返回类似的错误。 我有这个函数： @bot.command()
async def start(ctx):
"""starts the server"""
try:
status = server.status()
await ctx.channel.send("The server is already online!")
except:
浏览 30提问于2020-04-16得票数 2
在Python中-使用纯a = yield协程语法，而不是像asyncio这样的库-在收到响应之前发出一个HTTP请求并做一些其他事情，这是可能的吗？类似于： >>>requests.get('http://www.json-generator.com')
# do something else here while the above request is being made 就像使用AJAX一样，人们可以发出请求，而不必等待响应？或者我可能误解了协程背后的想法？
浏览 27提问于2019-01-07得票数 4
回答已采纳
2回答
协程是简化并发编程的一个很好的范例。大多数情况下，并发任务很容易并行化。在语言中，使用goroutines执行并行任务是很容易的。有没有办法在Python中做同样的事情，例如使用协程来创建进程并同步它们？
浏览 5提问于2011-06-30得票数 5
回答已采纳
我理解协程的原理。我知道如何让标准的StartCoroutine / yield return模式在Unity的C#中工作，例如，通过StartCoroutine调用一个返回IEnumerator的方法，在这个方法中做一些事情，做yield return new WaitForSeconds(1);等待一秒钟，然后做其他事情。
我的问题是:幕后到底发生了什么？StartCoroutine到底是做什么的？WaitForSeconds返回的IEnumerator是什么？StartCoroutine如何将控制权返回给被调用方法的“其他部分”？所有这一切如何与Unity的并发模型(其中许多事情在同一时
浏览 57提问于2012-10-17得票数 146
回答已采纳
典型的协程对象如下所示：
struct Coroutine
{
struct promise_type
{
int value;
Coroutine get_return_object() {return this; }
std::suspend_never initial_suspend() { return {}; }
std::suspend_never final_suspend() noexcept { return {}; }
void return_value(int v) {
浏览 0提问于2021-06-29得票数 0
1回答
龙卷风不能正确产生期货
、、、、
我需要在tornado请求处理程序中异步进行几个http调用。 尝试返回期货没有很好的文档记录，而且在龙卷风处理程序级别的聚集asyncio.gather上几乎不可能做到。 我已经尝试过aiohttp，它本身工作得很好，但是当把它放在一个tornado处理程序中时，它抛出的循环已经在使用了。如果你能告诉我如何在IOLoop中注入一些新的未来来解决这个问题，那就太好了。 我也尝试过使用tornados AsyncHTTPClient，与文档相反，它实际上没有使用yield，但在使用await时会返回响应。 有没有关于这方面的最新文档？所有示例都不适用于多个异步请求。 根据本文档http://w
浏览 11提问于2019-02-01得票数 0
回答已采纳
我是Python并发编程的新手。这是一个我必须处理的非常简单的例子，但它遇到了一个错误： class Parser(object):
def __init__(self):
self.parser = None
async def parse(self, text):
return text
async def call_parser(text):
parser = Parser()
parsed = await parser.parse(text)
if __name__ == "__main__":
浏览 5提问于2019-06-30得票数 1
回答已采纳
如何像围棋中的等待组一样，在lua中等待所有的协程完成？使用Semaphobe完成了go中的Waitgroup。但是如何在lua中完成它呢？或者其他更好的方案？
浏览 2提问于2020-01-28得票数 1
1回答
我期望的结果是(0，1)或(0，1，2)，但打印的数字不断增加。我在学习关于协程的知识。我遵循了这个例子，但我对它很好奇，所以我写了代码，发现了一些奇怪的东西。 class test {
@Test
fun test() = runBlocking {
val startTime = System.currentTimeMillis()
val job = launch {
var nextTime = startTime
var i = 0
while (isActiv
浏览 21提问于2021-07-25得票数 0
我很难理解asyncio的整个概念。现在，我尝试将Socket模块和asyncio一起使用，使UDP聊天同时作为服务器和客户端工作。在两个asyncio协程中，我运行循环(一个用于服务器，一个用于客户端)。但是程序只能作为客户端工作。在网络上发送数据，但不接收数据。我猜对于这种情况有更好的asyncio解决方案，但在继续之前，我想了解为什么特定的代码不工作。你有什么线索吗？
# PYTHON 3.4
import asyncio
import socket
PORT = 50001
MAX_BYTES = 8400
LOCAL_IP = ''
REMOTE_IP = '
浏览 2提问于2016-02-21得票数 1
已将torando v5.1迁移到v6。但是异步协程似乎已经被移除了。对它的修复有什么建议？ 将项目从2.7迁移到3.6，同时将tornado框架从v5.1迁移到v6.0.2，因为这个[Python code for DynamoDB query is working on v3.6 but not working in python 2.7 strackoverflow线程]中建议的错误。 安装v6 tornado后，它会中断，并出现以下错误。 Python3 xxxx.py
Traceback (most recent call last):
File "XXXX.py&#
浏览 84提问于2019-04-02得票数 1
1回答
在我的Unity3D游戏中，我试图创建一个火箭，当它的触发对撞机击中地图或玩家时会爆炸，摧毁投射物并在我的爆炸预制件中实例化。但是有了这段代码，当我玩这个游戏时，我的地面一直在消失。飞机上没有任何东西。这是我的代码。
void OnTriggerEnter (Collider c)
{
GameObject explosion = Instantiate (Explosion, c.transform.position, Quaternion.identity);
if (c.CompareTag("Projectile"))
{
De
浏览 0提问于2018-06-06得票数 0
1回答
我发现了一些关于使用yield from在Python 中修饰生成器函数的非常有用的信息。例如：
def mydec(func):
def wrapper(*args, **kwargs):
print(f'Getting values from "{func.__name__}"...')
x = yield from func(*args, **kwargs)
print(f'Got value {x}')
return x
return wrapper
@my
浏览 8提问于2018-08-31得票数 3
回答已采纳
1回答
我真的很欣赏Stackless Python的功能，我一直在寻找一种方法来模拟它的语法，同时仍然使用标准的Python3解释器。让它看起来像是greenlet库可以提供这种功能。我稍微修改了他的代码，但我能想到的最好的临时tasklet包装器是一个在变量中包含一个greenlet的类，如下所示：
class tasklet():
def __init__(self,function=None,*variables):
global _scheduled
self.greenlet = greenlet.green
浏览 4提问于2013-07-28得票数 0
我有一个使用asyncio和await模块的python程序。这是我取自的一个示例程序。
import asyncio
import os
import urllib.request
import await
@asyncio.coroutine
def download_coroutine(url):
"""
A coroutine to download the specified url
"""
request = urllib.request.urlopen(url)
filename = os.
浏览 3提问于2016-08-04得票数 2
2回答
我有一个关于co_await在C++中工作的问题。我有以下代码片段：
// Downloads url to cache and
// returns cache file path.
future<path> cacheUrl(string url)
{
cout << "Downloading url.";
string text = co_await downloadAsync(url); // suspend coroutine
cout << "Saving in cache.";
path p = rand
浏览 12提问于2021-05-25得票数 0
我对Coroutine的确切功能略知一二，所以我决定用它创建一个项目。最好的学习方式，不是吗？不管怎样，我在每个关卡的开头都有UI的工作脚本，它会告诉你什么关卡和/或它是否是一个新的检查点(产卵区域)。它还会告诉玩家还剩下多少生命和生命。我现在的问题是WaitForSeconds()没有暂停“检查点”文本，所以它直接进入图形用户界面函数，似乎跳过了检查点(Cpoint())函数。然而，通过调试日志，我知道它实际上不是这样的。这种变化在启动时发生得如此之快，以至于在读取之前就消失了。
我把协程注释掉了，因为它不间断地运行。我只想让这个代码在对撞机被联系的时候起作用。
欢迎所有的解释！我是来学习的
浏览 15提问于2018-08-25得票数 0
回答已采纳
重写方法on_finish()。用.gen.coroutine修饰这个方法以使其异步，它起作用了。
@gen.coroutine
def on_finish(self):
print("==========on_finish==============")
但是使用async def使其异步，它失败了。
async def on_finish(self):
print("==========on_finish==============")
# RuntimeWarning: coroutine 'BaseHandler.on_fini
浏览 1提问于2018-07-17得票数 4
我是第一次接触龙卷风，对龙卷风的协程有一些问题。如果我有一个调用堆栈，看起来像这样：
func_a => func_b => func_c => func_d
func_d是一个异步函数，我使用了yield和@gen.coroutine装饰器。
就像这样：
@gen.coroutine
def redis_data(self, id):
ret = yield asyn_function()
raise gen.Return(ret)
我必须将yield和@gen.coroutine与func_c、func_b和func_a一起使用吗
浏览 2提问于2015-03-03得票数 1
当您开始学习Kotlin协程时，您看到的第一个示例之一是可以启动数十万个协程，但在尝试对线程执行相同的操作时会遇到OutOfMemory异常。
虽然这个例子很“酷”，但我不认为它对现实世界的Android应用程序开发有什么用处，甚至有点误导。当然，您可以启动数十万个只做delay()的协程，但在现实中，您要么启动执行某种IO或某种计算的协程。
例如，如果您启动了数十万个协程，并且每个协程都使用Retrofit执行一个网络请求，那么它不会比传统地使用没有协程的Retrofit更轻量级，因为okhttp仍然会为每个请求阻塞一个线程。
当您使用协程进行计算时，情况也是如此。那么它也不是更轻量级的，因
浏览 1提问于2020-05-07得票数 3
我读过一些关于协程的文章，特别是关于python的，有些东西对我来说并不是很明显。
我实现了一个生产者/消费者模型，它的基本版本如下：
#!/usr/bin/env python
class MyConsumer(object):
def __init__(self, name):
self.__name = name
def __call__(self, data):
return self.observer(data)
def observer(self, data):
print self.__name +
浏览 0提问于2011-04-15得票数 4
回答已采纳
在Python语言中，await使用协程和使用asyncio.run()的实际区别是什么？它们似乎都在运行协程，我能看到的唯一区别是await只能在协程中使用。
浏览 12提问于2020-11-23得票数 7
回答已采纳
我正在开发一个Python-3程序，它试图做两件事：(1)从外部websocket (非阻塞)读取数据(类型1)和(2)在常规UDP套接字(非阻塞)上接收数据(类型2)。 在很长一段时间内，websocket和UDP套接字上都没有数据。因此，我尝试使两种数据类型的读取/接收都是非阻塞的。我正在尝试使用Asyncio和Websockets来为websocket执行此操作。 不幸的是，只要websocket上没有数据(类型1)，下面的代码就会挂起。它会阻止其余的代码执行。我做错了什么？ 提前感谢大家的帮助。 import asyncio
import websockets
import sock
浏览 45提问于2019-09-15得票数 8
回答已采纳
1回答
我正在尝试更好地理解aiohttp。有没有人可以检查一下为什么我的代码不打印请求的响应，而只是打印协程。 import asyncio
import aiohttp
import requests
async def get_event_1(session):
url = "https://stackoverflow.com/"
headers = {
'content-Type': 'application/json'
}
response = await session.request(&#
浏览 186提问于2020-08-14得票数 1
回答已采纳
我们有一个完全同步的应用程序，而且永远是同步的，因为它基本上是一个命令行解释器，向我们的硬件发送低级命令，你不能同时有两个命令到硬件上。对于这种配置，我将只有一个客户端套接字以同步方式操作，一个命令发送到服务器，它与硬件对话，并将值发送回客户端，但就我目前所见，async_read是执行非阻塞读取的唯一方法。
通过Beast获得非阻塞读/写的最佳方式是什么？例如，在Windows中的TCP和Serial中，您可以窥视缓冲区以查看数据是否准备好访问，如果有，您可以发出读取命令，知道它不会阻塞，因为数据在那里。我不确定我是否只是在Beast中错过了这个功能，尽管我会说如果可能的话，拥有这样的功能会
浏览 1提问于2018-04-24得票数 3
from quart import Quart, request, render_template, jsonify
import json
import os, sys
import pandas as pd
import requests
import asyncio
from pylon.model.db_models import RawFiles
from pylon.orm import db
app = Quart(__name__)
@app.route('/upload', methods=['POST'])
async def han
浏览 35提问于2020-09-05得票数 3
1回答
对异步函数的直觉
、、、
提前谢谢你，
假设你有一个异步函数：
async def create_list(num):
print("Creating a list that is length {}".format(num))
i = 0
list = []
While True:
i += 1
if i > 100000:
await asyncio.sleep(0.0001)
list.append(i)
if i == num:
浏览 4提问于2018-07-18得票数 0
1回答
正如中所述，我们可以使用asyncio.coroutine装饰器将函数转换为协程，如下所示：
def hello():
print('Hello World!')
async_hello = asyncio.coroutine(hello)
但是，从Python3.8开始，这个函数就被弃用了(被async def ...取代)。那么，如果没有async def ...，我们如何在3.8+中做到这一点呢
浏览 28提问于2021-03-05得票数 0
回答已采纳
使用aiobotocore，我使用以下命令创建客户端： import botocore
import aiobotocore
s3_session = aiobotocore.get_session(loop=loop)
client = s3_session.create_client(
's3',
config=botocore.client.Config(connect_timeout=10, read_timeout=10, retries={'max_attempts': 0}),
endpoint_url=endpoint
浏览 18提问于2019-09-16得票数 0
回答已采纳
目前，我正在尝试在FastAPI python中开发两个API，一个异步提交作业，另一个Get API根据请求回复您作业完成的当前状态。请帮助我实现这一点或任何其他标准的方式，通过它我可以利用在object中创建的AsyncResult对象。请参考下面的代码。
def worker(x):
#perform computation
# POST API which starts job
@app.post("/jobs/", status_code=HTTP_201_CREATED)
async def create_job():
浏览 3提问于2020-05-16得票数 0
1回答
我正在用Python制作一个不和谐的机器人。我想要做的是等待两个协程，一旦第一个完成，运行其余的代码，但取消剩余的协程(不像here，我只有一个协程，并希望它在特定的时间后被取消)。 下面是可重现的最小示例： import asyncio
import discord
client = discord.Client()
async def testfunc():
await asyncio.sleep(10)
print("10 seconds.")
async def testfunc2():
await asyncio.sleep(15)
浏览 16提问于2020-09-25得票数 0
回答已采纳
我向lua公开了一个基于C的API，它根据游戏引擎中的触发器调度lua协程。
我一直在使用同步线程(纤程)在我的gameloop中执行多任务lua，以维护一个我只在其上调用lua_resume的lua_Thread对象池。
重新阅读lua_resume/lua_yield文档意味着我应该关注一个大的内存泄漏，因为每个对lua_yield的调用都必须能够从某种堆栈中弹出状态信息？
浏览 0提问于2011-03-02得票数 0
回答已采纳
1回答
我的服务已经使用Websockets与tcp服务器通信，它还连接到另一个tcp端点。
它做两件事
1/ tcp从the服务器读取数据=>将其写入=>端点
2/ tcp从=>端点读取数据，并将其写入=>服务器。
我有以下代码来实现此目的
import websocket
import asyncio
def open_remote(reader):
print("open remote")
do_remote_read(reader)
def on_message(ws, message):
print("message re
浏览 10提问于2019-10-21得票数 0
1回答
using System;
using System.Collections;
using System.Collections.Generic;
using UnityEngine;
public class Shooting : MonoBehaviour
{
[SerializeField]
private Transform[] firePoints;
[SerializeField]
private Rigidbody projectilePrefab;
[SerializeField]
private float launchFo
浏览 11提问于2019-04-29得票数 0
回答已采纳
1回答
我正在运行一个python程序来监听azure iot集线器。该函数将返回一个协程对象，而不是json。我看到，如果我们使用异步函数并将其作为正常函数调用，则会发生这种情况，但我创建了一个循环来获取事件，然后使用run_until_complete函数。这里我漏掉了什么？
async def main():
try:
client = IoTHubModuleClient.create_from_connection_string(connection_string)
print(client)
client.connect()
浏览 8提问于2021-03-24得票数 1
我尝试在Python语言中异步运行for循环，就像在Javascript中使用map方法和promise.all所做的那样。我到处寻找如何做到这一点，但下面的代码仍然在同步运行(一个接一个地做，而不是像promise.all允许的那样，让循环在前一个循环结束时进行其他迭代)。任何帮助都将不胜感激。
from jwt import scopes
from googleapiclient.discovery import build
from google.oauth2 import servic
浏览 1提问于2019-08-01得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
