Python的异步`loop.create_task(...)`线程安全吗？
loop.create_task(...)是Python中用于创建一个异步任务（Task）的方法。异步编程是一种编程模型，它允许程序在进行I/O操作或其他耗时任务时不会被阻塞，以提高程序的并发性能。
在Python中，loop.create_task(...)是基于协程（Coroutine）的异步编程方式。协程可以看作是可以在某些点暂停执行并在需要时恢复执行的函数。loop.create_task(...)会将一个协程对象封装为一个任务对象（Task），并将其加入到事件循环（Event Loop）中进行调度执行。
关于loop.create_task(...)的线程安全性，需要注意以下几点：
- 异步编程在Python中通常使用单线程来实现并发性能，因此
loop.create_task(...)本身不涉及多线程操作，所以不会存在多线程安全的问题。 - 但是，当多个线程同时调用事件循环对象的方法时，例如使用
loop.create_task(...)创建多个任务，就需要考虑线程安全的问题。对于大多数事件循环实现（例如asyncio模块），它们在设计上是非线程安全的，即在多线程环境下不能同时操作同一个事件循环对象。 - 为了确保多线程环境下的安全性，可以采取以下措施之一：
- 使用锁（Lock）或其他同步机制来保护对事件循环对象的操作，以确保同一时间只有一个线程在操作事件循环对象；
- 在每个线程中创建独立的事件循环对象，并将任务分配到不同的事件循环中执行。
总结起来，loop.create_task(...)本身是线程安全的，但对于事件循环对象的操作需要注意线程安全性。在多线程环境下，需要采取适当的措施来保证对事件循环对象的操作不会发生竞争条件，以确保程序的正确性和稳定性。
推荐的腾讯云相关产品：
- 云函数（Serverless Cloud Function）：https://cloud.tencent.com/product/scf
- 弹性容器实例（Elastic Container Instance）：https://cloud.tencent.com/product/eci
相关·内容
谁能解释一下，如果我之前没有添加任何任务就开始循环，为什么我不能执行我的任务？(Python 3.7) import asyncio
import threading
def run_forever(loop):
loop.run_forever()
async def f(x):
print("%s executed" % x)
# init is called first
def init():
print("init started")
loop = asyncio.new_event_loop()
浏览 14提问于2019-03-16得票数 1
回答已采纳
Python抱怨RuntimeWarning: coroutine 'Queue.put' was never awaited
我搜索并看到了一个像这样的库来解决这样的问题。但是在3.8的时候有没有更好的方法呢？
更新。我能够使用create_task将项放到队列中，但是它要么是阻塞在get上，要么是put，直到系统中发生了其他异步事件才停止阻塞，尽管现在队列中应该有一个项，这样它就不需要阻塞了。知道为什么会发生这种事吗？它需要大约10-20才能自动解除阻塞，但是如果我发送另一个事件，它就会立即解除对前一个事件的阻塞，但是对于当前事件，也会有一个延迟，除非我发送另一个事件通过。
浏览 6提问于2019-11-28得票数 1
回答已采纳
我有一个应用程序，它将协同器添加到已经运行的事件循环中。这些协同机制的参数依赖于I/O，在我最初使用loop.run_forever()启动事件循环时是不可用的，所以我稍后会添加任务。为了演示这一现象，下面是一些示例代码：
import asyncio
from threading import Thread
from time import sleep
loop = asyncio.new_event_loop()
def foo():
loop.run_forever()
async def bar(s):
while True:
await asyn
浏览 0提问于2018-03-04得票数 2
回答已采纳
1回答
我正在开发一个机器人，它可以从Steem Blockchain流传输帖子(使用同步beem库)，并将满足特定条件的帖子发送到不一致通道(使用异步Discord.py库)。这是我的(简化)代码：
bot = commands.Bot(command_prefix="!")
async def send_discord(msg):
await bot.wait_until_ready()
await bot.send_message(bot.get_channel("mychannelid"), msg)
async def scan_post(
浏览 1提问于2018-09-20得票数 0
我试图用stream编写一个并发流处理程序，我想知道这是否是Python协同最有效的使用。asyncio包有大量的选项，但是很难确定项目的正确方法，我认为这些文档在解释每个项目的优缺点方面做得并不好。
我认为这里不需要多个线程的开销，我需要异步循环之间的相互通信。我应该为我的每个函数创建一个单独的BaseEventLoop吗？
作为Python，我认为这个问题(There should be one-- and preferably only one --obvious way to do it)有一个近乎确定性的答案，但我担心，添加所有这些异步巡洋舰可能只会使我的代码比完全顺序的天真实现更低
浏览 2提问于2016-01-27得票数 4
我修改了这段代码，以便在异步Python: PubSub中使用Google
import asyncio
import datetime
import functools
import os
from google.cloud import pubsub
from google.gax.errors import RetryError
from grpc import StatusCode
async def message_producer():
""" Publish messages which consist of the current date
浏览 2提问于2018-04-18得票数 2
回答已采纳
我正在尝试初始化一个非阻塞任务，它与其父对象共享数据。它是一个websocket客户端，它不会阻塞主执行，尽管它仍然“永远”运行。 我卑微的期望是这样做就可以了，但不幸的是，它阻塞了主线。 loop = asyncio.new_event_loop()
task = loop.create_task(self.initWS())
loop.run_forever()
浏览 39提问于2021-02-08得票数 0
我在VSCode中使用python，我想要实现的目标很简单：-在一个木星单元中异步启动任务，然后在下面的单元格中停止它。但在我的例子中，它不起作用--当我在一个单元格中启动异步任务时，在另一个单元格中启动任务，等待第一个单元格结束时。有人能解释我做错了什么吗？这是我的密码
细胞1
import asyncio
import nest_asyncio
nest_asyncio.apply()
i = 0
is_cancel_request = False
async def some_async_function(i):
while is_cancel_request ==
浏览 9提问于2022-10-20得票数 0
3回答
我在JS中有这个new_lock函数，它对避免回调地狱很有用： function new_lock(){
var unlock,lock = new Promise((res,rej)=>{ unlock=res; });
return [lock,unlock];
}
var [lock,unlock] = new_lock();
call_some_func_with_callback(data,function(){
print(1);
print(2);
unlock();
});
await lock;
print(3) 这是我的异
浏览 53提问于2020-12-02得票数 1
回答已采纳
我的目标是练习使用asyncio库。我已经读了一些入门教程，现在我想自己写一些代码。 我想开始两个简单的任务，这两个任务基本上是增加存储在外部类中的常用值。第一个是在5秒后自动递增1。第二个任务是与用户相关的:如果您在这5秒内输入了一些值，那么它也应该被添加。 问题是，当我没有输入任何值时，我的循环不会关闭-程序仍然是活动的，并且永远运行，直到我强制停止它-然后我得到以下错误： 2.py
[Auto_increment: ] This task will increment value after 5 seconds
[Manual increment: ] Waiting 5s for i
浏览 58提问于2019-06-15得票数 0
希望下面的代码能够解释我想要做的比问题标题更好的事情。
import asyncio
import time
loop = asyncio.get_event_loop()
class Foo(object):
def __init__(self, num):
self.num = num
@property
def number(self):
# Somehow need to run get_number() in the loop.
number = self.get_number()
retur
浏览 0提问于2015-07-22得票数 2
回答已采纳
1回答
最近，我一直在玩python 3异步特性。总的来说，我对3.6语法很满意，当然性能也会提高。在我看来，围绕ASGI标准发展的令人兴奋的项目之一是。我有一个示例应用程序，运行在读取hdf5文件中的数据的地方。h5py还不支持异步I/O。这就留给我一个问题:我在这里所做的一切有意义吗？据我理解，这段代码毕竟是同步运行的。在异步上下文中执行I/O的推荐方法是什么？
async def _flow(indexes):
print('received flow indexes %s ' %indexes)
# uses h5py under the hood
gr
浏览 0提问于2018-11-30得票数 2
我在主线程上运行matplotlib，其中包含来自外部源的实时数据图。为了处理传入的数据，我有一个简单的UDP侦听器，使用asyncio侦听包，事件循环在单独的线程上运行。 我现在想要添加更多的源代码，并且我想在与第一个相同的循环/线程上运行它们的侦听器。为此，我只是将循环对象传递给实现侦听器的类，它们的构造函数会向循环添加一个任务，该任务将初始化并运行侦听器。 但是，因为这些类是在主线程中初始化的，所以我从主线程调用loop.create_task(...)函数，而不是调用循环的线程。这会引起什么问题吗？
浏览 231提问于2021-10-07得票数 0
如果此函数在异步中作为任务运行：
async def test():
x = "strange"
while True:
def myfunc():
global x
x = "expected"
myfunc()
print("This is " + x)
await asyncio.sleep(1)
loop.create_task(test())
loop.run_forever()
我希望“这是预期的”，和任
浏览 2提问于2021-12-02得票数 1
回答已采纳
我已经写了一个异步函数，它收集多个文本数据，并进行批量数据处理。在此之后，它返回输出，如下所示：
import sys
import asyncio
Model_runner():
'''
The model runner combines all the input coming to it and combines in a batch of 10 or 1 sec, which ever duration is less.
After combining, it does processing and returns the outpu
浏览 0提问于2020-10-13得票数 0
嗨，我有下面的脚本，它侦听Google消息，在回调中，我将消息传递给另一个具有循环参数的脚本。
在第二个脚本中，我有一个具有依赖未来函数的任务。但未来的函数永远不会被调用。
import os, time
import base64, json
import asyncio
from google.cloud import pubsub_v1
from app.libs.pubsub.pubsub_connect import PubsubConnect
from app.config import config
from evergage.scripts.evga_process impor
浏览 0提问于2018-03-28得票数 1
回答已采纳
我使用的是Python3，下面的代码在运行异步工作线程池时尝试捕获CTRL+C。每个工作进程都会在无限循环中运行，等待消息出现在队列中进行处理。我不明白的是，为什么当我按CTRL+C时，except块中的log.info和print消息没有打印出来，它只是让我回到了xterm。with代码块是否在做一些事情来防止这种情况？ def worker(q):
"""Worker to retrieve item from queue and process it.
Args:
q -- Qu
浏览 21提问于2020-04-17得票数 0
假设我有一个主程序，它启动许多异步活动，所有这些活动都等待队列来完成工作，然后在ctrl上正确地关闭它们:它可能如下所示：
async def run_act1_forever():
# this is the async queue loop
while True:
job = await inputQueue1.get()
# do something with this incoming job
def run_activity_1(loop):
# run the async queue loop as a task
coro = loop.creat
浏览 4提问于2021-12-30得票数 1
1回答
来自多个方法的调用阻塞方法
、、、、
我在一个线程类中有一个websocket，它调用on_message函数send_conf()上的方法
但是在一个并行线程上有一个方法，也是每10秒调用一次相同的函数
我尝试在asyncio中使用run_in_executor，但收到“事件循环已在运行”错误。
从websocket.on_message和并行线程同时调用此send_conf()函数而不阻塞的最佳方法是什么？
import websocket, threading, json, base64
import time, requests, threading, asyncio
from concurrent.futures imp
浏览 1提问于2018-03-27得票数 0
因此，我在摆弄Python的asyncio，并使用loop.create_task(myfunct())创建新的未来。当myfunct()完成时，它会返回。由于我使用loop.run_until_complete(..)创建了我的循环，所以我希望create_task创建的线程一旦函数完成就会被销毁。但是，当我在中查看process时，我看到线程从未被销毁。
进程启动时的线程:7
完成一些工作后的线程(并完成)：25
这里出什么问题了？
import sys
import asyncio
async def async_process_line(line):
print
浏览 0提问于2018-07-03得票数 0
回答已采纳
我正在使用Suds从python访问SOAP web服务。如果我有多个threading.Thread执行线程，每个线程是否可以安全地并发访问相同的suds.client.Client实例，或者必须为每个线程创建单独的客户端对象？
浏览 0提问于2010-06-08得票数 5
1回答
所以我很抱歉，因为我看到这个问题问了很多人，但是看过所有的问题后，似乎没有人能解决我的问题。我的代码如下所示
TDSession = TDClient()
TDSession.grab_refresh_token()
q = queue.Queue(10)
asyncio.run(listener.startStreaming(TDSession, q))
while True:
message = q.get()
print('oh shoot!')
print(message)
orderEntry.placeOrder(TDSession=
浏览 2提问于2021-01-03得票数 3
回答已采纳
3回答
我试图制作一个带有aiohttp请求和异步任务的Pyqt5应用程序。我也使用quamash包，它需要Python3.7，所以我安装了这个版本(它在Python3.10上不起作用)我使用异步和quamash的主要原因是我想做请求，而不冻结应用程序的GUI。
当我点击“开始”按钮并关闭应用程序时，我会得到这个错误：
Task exception was never retrieved
future: <Task finished coro=<App.rotator() done, defined at C:\Users\Zsolt\Documents\python-example\st
浏览 12提问于2021-12-18得票数 4
回答已采纳
我试图使用asyncio调用一个REST API async，但我一直收到错误"coroutine was never awaited“，这是我理解的。但是我想要这样的行为，我希望我的函数只通过发布而不是等待结果来结束。以下是我的代码
async def callCoroutine:
#call a REST API
def lambda_handler(event, context):
loop = asyncio.get_event_loop()
task = loop.create_task(callCoroutine(data))
re
浏览 3提问于2018-08-03得票数 2
2回答
我正在编写一个简单的Python程序，它使用asyncio.coroutines维护一个字典。其设计是每个协程向字典中添加一个具有不同键的条目。我的问题是，当我修改字典以避免竞争条件时，我需要同步吗？换句话说，写入字典是原子的吗？
下面是我的程序：
map ={}
key_set = Set(...)
@asyncio.coroutine
def update(key):
# do I need synchronization here to avoid race condition?
map[key] = ... # add a new entry with key to
浏览 0提问于2017-03-25得票数 4
我很难理解Python3.7中引入的asyncio.create_task()函数是如何工作的。如果我这样做了：
import asyncio
async def helloworld():
print("Hello world from a coroutine!")
asyncio.create_task(helloworld())
def main():
loop = asyncio.get_event_loop()
loop.run_until_complete(helloworld())
if __name__ == "__
浏览 54提问于2018-08-04得票数 16
回答已采纳
我试图制作一个简单的用户界面，用户在图像中选择一些像素坐标。我正在考虑使用matplotlib来完成这个任务，因此我遇到了一个堆栈溢出问题：
其中，给出了将单击坐标存储在全局列表中的解决方案。
import numpy as np
import matplotlib.pyplot as plt
x = np.arange(-10,10)
y = x**2
fig = plt.figure()
ax = fig.add_subplot(111)
ax.plot(x,y)
coords = []
def onclick(event):
global ix, iy
ix, i
浏览 6提问于2016-01-18得票数 1
回答已采纳
1回答
我必须做大量的DNS NAPTR查找(想想每分钟数千)。我使用dnspython运行Python脚本，读取一个文件并将其写回另一个文件。请求速率为300次/秒。我尝试在Python中使用异步DNS，但是数字是相同的。我的剧本可能有瑕疵。请看下面的内容。这是Python3.4。
但是，如果结果必须返回到一个文件，那么甚至可以异步地进行查找吗？
import asyncio
import aiodns
...
loop = asyncio.get_event_loop()
resolver = aiodns.DNSResolver(loop=loop)
resolver.nameservers
浏览 0提问于2018-07-12得票数 0
回答已采纳
1回答
对于在python语言中如何定义线程安全性，我感到非常困惑。
有人说通过实现是CPython。
另一方面，说这是不安全的。
当他们谈论线程安全的时候，他们似乎有不同的含义。那到底是什么？
浏览 3提问于2017-11-07得票数 1
1回答
无法使我的异步函数正常工作
、、、、
我试图基于WebSocket提供的数据构建一个脚本，但我有一个棘手的问题无法解决。我有两个牢房。
第一项：
msg = ''
stream = {}
async def call_api(msg):
async with websockets.connect('wss://www.bitmex.com/realtime?subscribe=quote:XBTUSD,quote:ETHU19') as websocket:
await websocket.send(msg)
while websocket.open:
浏览 0提问于2019-08-31得票数 1
回答已采纳
我正在尝试创建一个Python脚本，它将从websocket连接接收消息，每次它接收到新消息时，它都需要在后台运行一个异步任务。 为了“模拟”这个过程，我做了一个阻塞函数，它用一条while True语句开始计数。预期的输出是，每次从ws连接接收到新消息时，都会启动一个新的计数，但在我的示例中，只要我一运行脚本，count函数就会阻塞整个代码。我该如何解决这个问题呢？ 这是我尝试过的： import asyncio
import websockets
import json
import time
#this is the blocking function..
def counter()
浏览 68提问于2021-11-10得票数 2
回答已采纳
使用discord.py制作一个不和谐的机器人，这是我第一次使用异步操作，也可能是我第一次在Python中遇到令人沮丧的事情。
这个问题的重点不是教我如何使用异步，而是教我如何避免使用异步，即使这不是正确的方法。
因此，我需要运行来自常规def函数的不和谐客户端协同。经过几个小时的搜索，我发现了这个：asyncio.get_event_loop().run_until_complete(...)。我设置了一个小脚本来测试它：
import asyncio
async def test():
print('Success')
asyncio.get_event_loo
浏览 21提问于2017-10-21得票数 3
回答已采纳
1回答
我有3个python脚本
grab.py:以Instagram帐户名作为输入，并输出包含所有追随者的文本文件。
scrape.py:以grab.py的输出作为输入，并以csv形式输出每个帐户的详细信息(追随者计数、post计数等)。
analyze.py:是一种基本的机器学习模型，它使用scrape.py的结果对帐户进行分析。
这3个脚本按预期的方式单独工作。下一步是创建一个API端点，它将以一个帐户名作为请求参数，然后为接收到的帐户触发上述3个脚本。最终的分析结果将存储在数据库中。
端点还需要有一个排队机制来存储接收到的帐户名。队列将被轮询，如果帐户名可用，它们将按顺序处
浏览 1提问于2019-03-13得票数 0
1回答
我正在使用一个带有async函数的python API包装器。我需要多次调用API，并希望在进入下一次迭代之前，通过等待每个任务完成来覆盖async功能。
import asyncio
loop = asyncio.get_event_loop()
for count in range(5):
loop.create_task(main(count)) # Need this line to complete before next iteration
time.sleep(60) # Hacky solution
目前我只是在睡觉，直到我可以假设main()已经完成。如何确保
浏览 2提问于2020-12-05得票数 2
2回答
我一直在尝试同时运行两个函数，但其中一个似乎从未起作用，除非我阻止另一个。第一个函数每30秒发送一封电子邮件，而第二个函数每5秒打印一次简单的语句。综合起来，每6个"Hello“输出应该发送一封电子邮件。
然而，我从来没有收到一封电子邮件，除非打印更改为提前停止，例如在10秒后结束。在不停止的情况下，我怎样才能同时运行这两个程序呢？
async def timer():
end = time.time() + 30
while True:
if time.time() >= end:
sendmail(name, filep
浏览 1提问于2020-06-20得票数 3
回答已采纳
1回答
上下文:我想查询内存中的dict结构，并使用相同的查询函数来触发一些后处理任务(比如获得附加到dict的扩展信息，因此名为exinfo)，因为我不希望在“关键处理路径”中包含这些任务。Asyncio的行为很奇怪，可能是因为我做错了什么。只有当我在运行task_resolve_names线程之前取消注释"hello“测试任务时，task_save和run_forever才会被执行。我很感激你的帮助。
exinfo.py
import os, sys
from os import path
import pickle
import asyncio
import threading
impo
浏览 2提问于2020-09-22得票数 0
回答已采纳
运行在Windows10，Python3.6.3上，运行在PyCharm IDE中，代码如下：
import asyncio
import json
import datetime
import time
from aiohttp import ClientSession
async def get_tags():
url_tags = f"{BASE_URL}tags?access_token={token}"
async with ClientSession() as session:
async with session.get(url
浏览 1提问于2018-10-11得票数 1
回答已采纳
我正在使用Python3.5和Tkinter创建一个加密货币交换API客户机。我想每10秒异步更新几个显示器。如本例所示，我可以使用Tk.after()每10秒更新一次显示。
def updateLoans():
offers = dd.loanOffers()
demands = dd.loanDemands()
w.LoanOfferView.delete(1.0, END)
w.LoanDemandView.delete(1.0, END)
w.LoanOfferView.insert(END, offers)
w.LoanDemandVi
浏览 0提问于2018-04-21得票数 3
回答已采纳
1回答
这可能是一个非常简单的答案，但我是创建自己的python应用程序和包的新手。我非常熟悉像C++和C#这样的语言和它们的库。
我正在尝试构建一个python包，我希望它能像一个简单的可执行文件一样运行。我为这个应用程序提供了支持模块，这些模块只是被实例化和调用的类。然而，我确实有一个问题。我有两个主要的函数。我背后的原因是我有程序的一部分，它由简单的for循环组成，它实例化一个类，然后给出关于这个类的具体细节(输入进入它等)，我创建了一个调用'python smartinterface.py‘的Popen实例，而smartinterface.py包含了另一个主函数。我想知道如何才能最好地
浏览 1提问于2016-10-30得票数 0
我知道互联网上充斥着关于推特提出的"RuntimeError:主线程不在主循环“的问题。但是几乎所有的人都讨论如何并行运行线程。我不知道(至少我想是这样)。我的问题是:代码完全独立运行。但是，只要在调试模式中显示GUI，就只需要几秒钟的问题，直到这个运行时错误发生。我的猜测是:调试器本身运行在一个并行线程中？！？如果我是对的，我能做些什么？如何可靠地调试使用TKinter的代码？
版本：
代码1.68
Python 3.9.13
最起码的例子：
import tkinter as tk
import tkinter.ttk as ttk
class GUI(ttk.
浏览 13提问于2022-06-10得票数 1
我在一个正在开发的python项目中使用。websocket正在一个线程中运行，并从父线程获得2个。我正在使用javascript连接到websocket服务器。
我能够通过self.ssi.get(True)从父线程获取消息，并将它们传递给javascript websocket客户端。
但我无法接收来自客户端的消息。当我使用zaproxy时，我可以看到消息正在通过。在websocket服务器上，我也能够看到数据包到达接口。Python不会抛出错误，logger.setLevel(logging.DEBUG)也不会像我看到发送的消息那样显示到达的消息。
我一直在尝试解决这个问题，但我已经没有
浏览 23提问于2018-02-14得票数 1
回答已采纳
2回答
在中，我读到，理想情况下，您应该为每个应用程序创建一个ClientSession。我怀疑这应该是类似于“每个线程创建一个ClientSession”(我使用的是Python3x)。
import aiohttp
import asyncio
async def get_it_async(url: str, session):
async with session.get(url) as resp:
print(resp.status)
print(len(await resp.text()))
def run_it(fn, *args, **kwar
浏览 0提问于2020-07-03得票数 1
在使用asyncio.start_server()测试服务器程序时，该方法似乎没有调用第一个client_connected_cb方法。当程序在测试之外单独运行时，它将按预期的方式工作。我怀疑这与没有正确处理事件循环有关。
为了进行测试，我有一些非异步代码连接到套接字服务器，当侦听套接字时，套接字服务器将无限期挂起。
为什么事件循环不处理单元测试中的服务器代码？
测试：
@pytest.mark.asyncio
async def test_connect(server, connection):
await server.start()
connection.connect(
浏览 0提问于2018-03-21得票数 0
回答已采纳
我们都知道，使用异步大大提高了套接字服务器的性能，显然，如果我们能够利用cpu中的所有内核(可能通过多处理模块或os.fork()等)，事情会变得更棒。
现在，我正在尝试构建一个多核套接字服务器演示，一个异步套接字服务器监听每个核心，并且所有绑定到一个端口。只需创建一个异步服务器，然后使用os.fork()，就可以让进程具有竞争力。
然而，当我试图分叉时，单核精细代码会遇到一些麻烦。似乎在epoll选择器模块中注册来自不同进程的相同文件压缩程序存在一些问题。
我给你看了下面的代码，有人能帮我吗？
下面是一个简单的、逻辑上清晰的回显服务器代码，它使用异步：
import os
import a
浏览 1提问于2019-06-01得票数 2
回答已采纳
我想用python写一个小的网络爬虫。我开始研究将其编写为多线程脚本，一个线程下载池和一个池处理结果。由于有了GIL，它真的可以同时下载吗？GIL对网络爬虫有什么影响？会不会每个线程从套接字中提取一些数据，然后转到下一个线程，让它从套接字中提取一些数据，等等？
基本上我想问的是，用python做一个多线程爬虫真的比单线程能给我带来更多的性能吗？
谢谢!
浏览 4提问于2010-05-14得票数 10
回答已采纳
1回答
为了实现服务器，我一直试图理解asyncio模块。我在看问题，它似乎问了一个类似的问题，如果不是相同的问题的话，但是我仍然试图理解在场景后面发生的工作流。
我有一个简单的程序，它有两个协同线，一个从终端读取并放入队列，另一个协同线等待队列中的项目，然后简单地将它们打印回屏幕。
import asyncio
q = asyncio.Queue()
async def put():
while True:
await q.put(input()) #Input would be normaly something like client.recv()
浏览 6提问于2022-03-15得票数 2
1回答
我想知道是否可以在不将main设置为异步的情况下创建异步函数。
我有一个这样的函数呼叫：
async def C:
t = asyncio.create_subprocess_shell(command)
...
await t
def B:
asyncio.set_event_loop(asyncio.new_event_loop())
C()
<How to await for C?>
def A:
B()
我无法等待C(作为一项任务或未来)。函数在启动C()后立即退出。我尝试过loop.create_task和loo
浏览 3提问于2020-02-19得票数 0
回答已采纳
1回答
我试图同时向主机发送SSH/Ping，但没有看到任何结果，因此，可能我的实现是不正确的。这就是我到目前为止所拥有的。任何想法都很感激。
import paramiko
import time
import asyncio
import subprocess
async def sshTest(ipaddress,deviceUsername,devicePassword,sshPort): #finalDict
try:
print("Performing SSH Connection to the device")
浏览 8提问于2022-02-18得票数 0
回答已采纳
2回答
我试图了解出现在Python3中的新异步功能。
我从堆栈溢出中找到的一个简单的工作人员示例开始，稍微修改了一下：
import asyncio, random
q = asyncio.Queue()
@asyncio.coroutine
def produce(name):
while True:
value = random.random()
yield from q.put(value)
print("Produced by {0}".format(name))
yield from asyncio
浏览 7提问于2016-03-04得票数 2
回答已采纳
当我阅读一些有关Nginx的材料时，我注意到在单个套接字上接受传入连接的2种传统方法之一是：
在单个端口上运行的多线程服务器使用的第二种传统方法是让所有线程(或进程)在表单的简单事件循环中对单个侦听套接字执行accept()调用: while (1) { new_fd =accept(.)；process_connection(New_fd)}；
引用自所以_REUSEPORT套接字选项。
然后我注意到Nginx似乎也采用了这种方法。
如图所示，当未启用SO_REUSEPORT选项时，单个侦听套接字会通知工作人员传入连接，每个工作人员都试图获取一个连接。
📷
引用自NGINX版本1.9.1中的
浏览 0提问于2020-08-23得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
