Trung tâm cá nhân
sách gpt4 ăn đã đi

Python 异步 : event loop does not seem to stop when stop method is called

In lại 作者：太空狗 更新时间：2023-10-29 20:46:54 27 4
mua khóa gpt4 giày nike

我有一个简单的测试，我使用 run_forever 方法运行 Python asyncio 事件循环，然后立即在另一个线程中停止它。但是，事件循环似乎并没有终止。我有以下测试用例:

import asyncio
from threading import Thread

loop = asyncio.get_event_loop()
thread = Thread(target=loop.run_forever)
thread.bắt đầu()
print('Started!')
loop.stop()
print('Requested stop!')
thread.join()
print('Finished!')

这个测试用例打印:

Started!
Requested stop!

因此，测试似乎在 thread.join() 上阻塞，等待事件循环终止。

如果我转储我的线程，我会得到以下信息:

Thread 0x00007000087ec000 (most recent call first):
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/selectors.py", line 577 in select
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/asyncio/base_events.py", line 1388 in _run_once
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/asyncio/base_events.py", line 421 in run_forever
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/threading.py", line 862 in run
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/threading.py", line 914 in _bootstrap_inner
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/threading.py", line 882 in _bootstrap

Current thread 0x00007fffc6b273c0 (most recent call first):
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/threading.py", line 1070 in _wait_for_tstate_lock
  File "/Library/Frameworks/Python.framework/Versions/3.5/lib/python3.5/threading.py", line 1054 in join

我没有深入研究 Python 代码，但 selectors.py 似乎正在等待工作。我想这个问题的发生可能是因为我调用了 dừng lại 而事件循环没有更多的工作要做，但这似乎是一个很有问题的限制。

或者我可能误解了它应该如何工作？

câu trả lời hay nhất

tài liệu says关于事件循环类:

This class is not thread safe.

Vàfurther :

An event loop runs in a thread and executes all callbacks and tasks in the same thread. [...] To schedule a callback from a different thread, the AbstractEventLoop.call_soon_threadsafe() method should be used. Example:

loop.call_soon_threadsafe(callback, *args)

似乎是我们需要的:

import asyncio
from threading import Thread

loop = asyncio.get_event_loop()
thread = Thread(target=loop.run_forever)
thread.bắt đầu()
print('Started!')
loop.call_soon_threadsafe(loop.stop) # here
print('Requested stop!')
thread.join()
print('Finished!')

打印:

Started!
Requested stop!
Finished!

关于Python 异步 : event loop does not seem to stop when stop method is called，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/46093238/

27 4 0
Đề xuất bài viết: C++:为什么不能编译？
Đề xuất bài viết: c# - WinForms 中的 3D？
Đề xuất bài viết: c# - File.WriteAllBytes 或 FileStream.Write
Đề xuất bài viết: c# - 伊朗手机号码的正则表达式？
太空狗
Hồ sơ

Tôi là một lập trình viên xuất sắc, rất giỏi!

Nhận phiếu giảm giá taxi Didi miễn phí
Phiếu giảm giá taxi Didi
Các bài viết phổ biến trên toàn bộ trang web
Chứng chỉ ICP Bắc Kinh số 000000
Hợp tác quảng cáo: 1813099741@qq.com 6ren.com
Xem sitemap của VNExpress