在单独的线程中调用asyncio.run()时为ValueError
在单独的线程中调用asyncio.run()时出现ValueError的原因是asyncio.run()函数只能在主线程中调用。asyncio.run()函数是Python 3.7版本引入的一个方便的函数，用于运行一个async函数作为主协程。它会创建一个事件循环并在其中运行给定的协程，直到协程完成为止。
由于asyncio.run()函数需要在主线程中调用，如果在其他线程中调用会导致ValueError异常。这是因为asyncio.run()函数会检查当前线程是否为主线程，如果不是则会抛出异常。
解决这个问题的方法是将asyncio.run()函数放在主线程中调用。可以使用多线程编程的方式，将需要在单独线程中调用的代码放在一个线程函数中，然后通过线程调用asyncio.run()函数。
以下是一个示例代码：
import asyncio
import threading
def async_thread():
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
loop.run_until_complete(asyncio.run(main()))
def main():
# 在这里编写需要在单独线程中调用的代码
pass
if __name__ == "__main__":
if threading.current_thread() is threading.main_thread():
asyncio.run(main())
else:
async_thread()在上面的示例代码中，我们定义了一个async_thread()函数，该函数会创建一个新的事件循环并在其中运行asyncio.run(main())。然后，在主程序中，我们检查当前线程是否为主线程，如果是则直接调用asyncio.run(main())，否则通过调用async_thread()函数在单独线程中运行。
这样就可以避免在单独的线程中调用asyncio.run()函数时出现ValueError异常。
相关·内容
1>Python Asyncio没有使用asyncio.run_coroutine_threadsafe运行新的协程。下面是在Mac上执行的代码测试。
import os
import random
import asyncio
import logging
from concurrent.futures import ThreadPoolExecutor
os.environ['PYTHONASYNCIODEBUG'] = '1'
logging.basicConfig(level=l
浏览 0提问于2019-12-22得票数 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
我知道在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
回答已采纳
我想运行一个使用协程和多线程请求urls的服务。但是，我不能将协程传递给executor中的worker。有关此问题的最小示例，请参阅以下代码：
import time
import asyncio
import concurrent.futures
EXECUTOR = concurrent.futures.ThreadPoolExecutor(max_workers=5)
async def async_request(loop):
await asyncio.sleep(3)
def sync_request(_):
time.sleep(3)
async def
浏览 0提问于2017-09-06得票数 22
背景:我正在托管一个flask服务器和一个不一致的客户端
flask服务器只需要将来自客户端的消息传递给discord，并将来自discord的消息传递给客户端。
调用loop.run_until_complete(sendMsg(request))时出现错误，我在sendMsg和wait_for loop.run_until_complete()中尝试了wait_for
我到处都找过了，但没有找到任何东西，所以如果有任何帮助，我将不胜感激。
代码：
import discord
import json
import os
import asyncio
from flask import Fl
浏览 0提问于2018-09-08得票数 15
我有一个下面的代码：
import time
import asyncio
from concurrent.futures import ProcessPoolExecutor
def blocking_func(x):
print("In blocking waiting")
time.sleep(x) # Pretend this is expensive calculations
print("after blocking waiting")
return x * 5
@asyncio.coroutine
def mai
浏览 0提问于2018-04-27得票数 0
我试着用运行下面的代码
import asyncio
async def test():
for _ in range(3):
print("Test")
await asyncio.sleep(1)
loop = asyncio.get_running_loop() # Here
loop.run_until_complete(test())
但是，我发现了下面的错误：
RuntimeError:不运行事件循环
我可以用下面所示的代替来运行上面的代码，但是自从3.10版本的之后，就不再受欢迎了，所以我不想使用它。
# ...
浏览 14提问于2022-10-31得票数 0
我正在尝试创建一个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
回答已采纳
我尝试在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
1回答
我从BaseServer继承了我的服务器类
class BaseServer(object):
def __init__(self, host, port):
self.loop = asyncio.new_event_loop()
asyncio.set_event_loop(self.loop)
self.instance = asyncio.start_server(self.handle_connection, host = host, port = port)
async def handle_connection
浏览 0提问于2018-11-04得票数 2
回答已采纳
我试图用Python交替运行test1() 2异步函数、test2()和test2()，如下所示：
import asyncio
async def test1():
for _ in range(3):
print("Test1")
await asyncio.sleep(1)
async def test2():
for _ in range(3):
print("Test2")
await asyncio.sleep(1)
loop = asyncio.n
浏览 12提问于2022-10-29得票数 0
我尝试执行asynchronous requests，如下所示：
# Example 2: asynchronous requests
import asyncio
import aiohttp
import time
import concurrent.futures
no = int(input("time of per "))
num_requests = int(input("enter the no of threads "))
no_1 = no
avg = 0
async def fetch():
async with aiohttp.C
浏览 0提问于2018-02-14得票数 4
回答已采纳
我有一个Django应用程序，在它的一个视图中，我使用异步来向外部组件发出一些一致的请求。
以下是这样的想法：
import asyncio
async def do_request(project):
result = ...
return result
def aggregate_results(projects: list):
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
results = loop.run_until_complete(
as
浏览 11提问于2021-12-10得票数 3
回答已采纳
1回答
无等待的异步任务队列
、、、、
我有一个无限循环，它正在从相机捕获视频。偶尔会获取一张图像，并对其进行处理以找到人脸。该进程可以作为后台任务运行，因为主进程不需要来自它的响应。那么，有没有一种方法可以在不停止主循环的情况下创建一个异步任务队列呢？
换句话说。我需要创建一个同时运行主循环的任务队列，这个队列可以向队列中添加更多的任务。
我试过用asyncio来做这件事，但它不起作用。我期望的输出是这样的：
Main loop
Main loop
Main loop
hello
Main loop
hello
...
但是我得到了：
Main loop
hello
浏览 3提问于2021-02-13得票数 3
1回答
我正在尝试创建两个线程，每个线程都有自己的异步事件循环。
我尝试了下面的代码，但它似乎不起作用：
import asyncio
from threading import Thread
def hello(thread_name):
print('hello from thread {}!'.format(thread_name))
event_loop_a = asyncio.new_event_loop()
event_loop_b = asyncio.new_event_loop()
def callback_a():
asyncio.set_eve
浏览 3提问于2018-09-12得票数 19
回答已采纳
我对此错误的理解是，它抱怨它不在异步def函数中。但是，我的是，我甚至使用了loop = asyncio.new_event_loop()和loop.run_until_complete(onInfoAsync(info,conn))。以下是错误：
Timeout context manager should be used inside a task
File "C:\Users\ianfi\Documents\pythonStuff\PyQt5\ServerCalling\main.py", line 42, in onInfoAsync
dm = await
浏览 5提问于2022-06-25得票数 0
1回答
所以我有一个基本的不一致机器人，它接受输入
import discord
import asyncio
import threading
loop = asyncio.new_event_loop()
bot = discord.Client()
def run_asyncio_loop(loop):
asyncio.set_event_loop(loop)
loop.run_forever()
Hangman.set_bot(bot)
@bot.event
async def on_message(message):
bot.loop.create_task
浏览 24提问于2017-08-09得票数 0
回答已采纳
5回答
我想在每次执行Flask路由时执行一个异步函数。为什么abar函数从未执行过？
import asyncio
from flask import Flask
async def abar(a):
print(a)
loop = asyncio.get_event_loop()
app = Flask(__name__)
@app.route("/")
def notify():
asyncio.ensure_future(abar("abar"), loop=loop)
return "OK"
if __name_
浏览 3提问于2017-12-16得票数 54
我只是在学习异步和线程，所以如果有什么问题，对不起
这是我的密码：
async def callback_onlyAlert(update: Update, context):
await update.message.reply_text('Ok! \nI will send you a message only when you can withdraw your USDN')
#run alert
t = threading.Thread(target=middleware_alert, args=(update, context,))
浏览 66提问于2022-11-05得票数 1
回答已采纳
我有两个文件，每个都运行在不同的线程上。一个用于运行烧瓶网站的主文件，一个用于独立线程中的不和谐机器人。我试图在不和谐方面调用异步方法，以便在收到请求后向用户发送消息。
#IN DISCORD FILE (discbot.py)
client = discord.Client()
async def registerSuccess(state, btag):
...
await client.wait_until_ready()
guilds = client.fetch_guilds()
async for guild in guilds:
浏览 1提问于2022-03-01得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
