15
async, например, задает асинхронную функцию
async def f():
return 5
Или указывает, что for асинхронный, т.е. получает значения из асинхронного генератора
async def generator():
yield 1
yield 2
yield 3
async def main():
async for x in generator():
print(x)
Или позволяет работать с асинхронной версией контекстного менеджера
...
13
Из документации:
The default policy defines context as the current thread, and manages
an event loop per thread that interacts with asyncio. If the current
thread doesn’t already have an event loop associated with it, the
default policy’s get_event_loop() method creates one when called from
the main thread, but raises RuntimeError otherwise.
По-...
ответ дан 20 фев '18 в 14:26
Sergey Gornostaev
64k66 золотых знаков4040 серебряных знаков9696 бронзовых знаков
13
Попытаюсь дополнить ответ @extrn.
async/await - это оптимизация, т.е. использовать их категорически не надо там, где все и так работает хорошо. Ведь это усложняет логику исполнения программы и тянет за собой много всего. Потому что если решились использовать асинхронную функциональность - будьте добры использовать ТОЛЬКО библиотеки, которые это поддерживают....
10
Не совсем понятно, что именно непонятно, поэтому я попробую упростить ответ максимально, прибегнув при этом к грубым допущениям. Да простят меня коллеги.
Сопрограмма (coroutine) — результат вызова асинхронной функции, представляющий собой выполнение этой функции, способное приостанавливаться. Так как в общем случае невозможно определить сколько раз и на ...
ответ дан 6 ноя '18 в 4:29
Sergey Gornostaev
64k66 золотых знаков4040 серебряных знаков9696 бронзовых знаков
6
Да.:
An event loop runs in a thread and executes all callbacks and tasks in the same thread.
asyncio.get_event_loop() возвращает цикл событий соответствующий текущему контексту. По умолчанию это текущий поток, то есть один цикл на поток. При вызове из coroutine, возвращается цикл, который эту coroutine выполняет:
When called from a coroutine or a ...
ответ дан 19 сен '17 в 19:32
jfs
49.2k99 золотых знаков9090 серебряных знаков276276 бронзовых знаков
6
Если функция, которую вы не хотите ждать занимается вычислительной работой, то asyncio тут не помощник. Асинхронность может достигаться несколькими путями - использованием нескольких потоков, процессов, сопрограмм и пр. Сопрограмма может сохранить свое состояние и переключиться на выполнение другой сопрограммы (или "основной" код). Простой пример (Py3.5+):
...
6
Для теста вот что получилось:
import ssl
import socket
incom = ssl.MemoryBIO()
outcom = ssl.MemoryBIO()
context = ssl.SSLContext(ssl.PROTOCOL_TLS)
context.check_hostname = False
context.verify_mode = ssl.CERT_NONE
context.load_cert_chain(certfile="ssl_cert.pem", keyfile="ssl_key.pem")
sslo = context.wrap_bio(incom, outcom, server_side=True)
serversocket ...
5
Асинхронно никак, но можно в executor'е.
import asyncio
def read_file(file_name):
return open(file_name).read()
async def main():
loop = asyncio.get_event_loop()
data = await loop.run_in_executor(None, read_file, 'data.txt')
print(data)
loop = asyncio.get_event_loop()
loop.run_until_complete(main())
ответ дан 31 мар '16 в 9:19
Sergey Gornostaev
64k66 золотых знаков4040 серебряных знаков9696 бронзовых знаков
4
input() - это блокирующаяся функция. Вызов блокирующихся функций в асинхронном коде блокирует цикл событий. Поэтому их надо запускать в отдельном потоке. Да и прерывание от клавиатуры вы так в асинхронном коде не поймаете. По-хорошему для этого надо назначать обработчик вызовом метода add_signal_handler(), но в Windows это не работает.
import asyncio
import ...
ответ дан 21 фев '18 в 18:04
Sergey Gornostaev
64k66 золотых знаков4040 серебряных знаков9696 бронзовых знаков
4
Хэширование - это CPU-bound операция, в то время как асинхронность позволяет получить преимущество только в I/O-bound операциях.
Предположим, что на всех графиках ось time - это константа. Последовательное выполнение my_algo трижды будет выглядеть так
Асинхронное выполнение трёх задач, выполняющих ту же функцию my_algo так
То есть это не настоящая ...
ответ дан 16 мая '18 в 7:46
Sergey Gornostaev
64k66 золотых знаков4040 серебряных знаков9696 бронзовых знаков
4
Чтобы воспроизвести ошибку, ваш случай сводится к следующим строкам:
#!/usr/bin/env python3
import asyncio
from tkinter import Tk, Button
async def main(): # XXX BROKEN: DO NOT USE!!!
async def coro():
pass
root = Tk()
Button(text='press me', command=coro).pack()
root.mainloop()
asyncio.get_event_loop().run_until_complete(main())
...
ответ дан 25 мар '18 в 21:17
jfs
49.2k99 золотых знаков9090 серебряных знаков276276 бронзовых знаков
4
asyncio реализует кооперативную многозадачность. Это значит, что websockets библиотека должна кооперировать (предоставлять возможность чисто завершить соединения). Был открыт баг на websockets Review cancellation management.
Даже для обычных (preemptive) потоков не существует общего решения, которое бы корректно остановило бы потоки вне зависимости от кода, ...
4
Вы не так поняли. Файлы можно читать неограниченное кол-во раз, но после каждого прочтения файла следует его закрывать, т.к. нередко Python начинает кричать неблагим матом и выводить кракозябры. Также возможно что вы не открыли нужный файл (самое первое обращение, например при работе с txt: t = open('myfile.txt')), либо прописали неправильное название. ...
4
Происходит примерно следующее
Модуль start начинает загружаться под именем __main__, это важно
На строчке import export его загрузка приостанавливается до полного исполнения кода модуля export
from start import test (у вас в коде опечатка) приостанавливает загрузку этого модуля, пока не будет загружен модуль start уже под именем start. То, что он уже ...
4
Судя по ошибкам, Вы запускаете get_app из синхронного колбэка асинхронного сервера. Иначе работало либо через первый, либо черезвторой способы.
Из колбэка получить результат можно только в новый колбэк. привет яваскрипт ;)
def second_cb(fut):
app_info = fut.result()
продолжение кода
def server_cb(request):
asyncio.ensure_future(get_app())....
4
Когда вы используете sleep нет гарантии сколько точно корутина будет спать. Если две будут спать и проснутся точно в то же время, то какая-то одна из них будет продолжена первой. Если нужно упорядочить их выполнение более строго, то на время и sleep полагаться нельзя.
Т.е у вас требование не просто "каждые три секунды", а "каждые три секунды, ...
4
Асинкио режет функцию на кучочки по слову await и выполняет новые кусочки пока эвейтит другой.
первый момент - стартуй по сто запросов, а не по одному:
while now < sec and self.place:
for _ in range(100):
tasks.append(asyncio.create_task(self.send_request(url2, data, headers))) #создание запросов
await asyncio.sleep(0)
now = time.time()...
3
Вызвать в цепочке можно так await (await (await A.m1()).m2()).m3() Выглядит жутко, но работает. Сделать именно так, как вам хочется, наверняка можно, но не стандартными средствами, насколько мне известно.
UPDATE:
Мне стало интересно и я накидал вариант
import asyncio
import random
class A:
async def m1(self):
print('TEST 1 BEGIN')
...
ответ дан 16 мар '16 в 4:36
Sergey Gornostaev
64k66 золотых знаков4040 серебряных знаков9696 бронзовых знаков
3
Давайте попробуем реализовать асинхронность по классике =) Асинхронность в отличии от синхронности заключается в том, что для каждого соединения мы должны создать контекст: некую структуру данных, которая будет хранить состояние соединения, информацию о том, что сейчас происходит на этом соединении. Действия же с соединением (чтение, запись и т.д.) ...
3
В решении с чанками есть 2 проблемы:
дождаться выполнения чанки целиком: если попадается один тормозной запрос - он тормозит всю очередь.
рекурсия делает новые чанки: при большой вложенности одновременных запросов может быть экспонециально больше 50
Получаются превышения производительности и простои, при том не компенсирующие друг друга.
Для равномерной ...
3
Видимо, уже нашли решение. Вот для тех, кто ищет:
Используйте asyncio.get_event_loop() чтобы получить уже существующий event loop:
loop = asyncio.get_event_loop()
loop.run_until_complete(some_function()) # Будет ждать, пока some_function не закончит выполнение.
Согласно документации, run_until_complete выполняет async функцию, при этом блокируя исполнение ...
3
asyncio.gather самый простой вариант - запускает все и ждет пока все будут готовы. Используй когда нужно получить все результаты для дальнейшей работы.
asyncio.as_completed выдает по одной задаче по мере готовности. Очень простой по синтаксису вариант. Используй для вывода или обработки результата по мере выполнения.
asyncio.wait сложный по синтаксису, но ...
3
async def task_periodic(ctx, arg):
i = 0
while True:
i += 1
await ctx.send(i)
await asyncio.sleep(10)
@bot.command()
async def task(ctx, arg):
if arg == 'on':
ctx.periodic = bot.loop.create_task(task_periodic(ctx, arg))
elif arg == 'off':
if hasattr(ctx,'periodic'):
ctx.periodic.cancel()
...
3
Как вариант, можно вынести функцию из класса, тогда не нужно будет передавать self:
import asyncio
from functools import wraps
def a(fun):
@wraps(fun)
async def wrapper(*args):
print(args)
return await fun(*args)
return wrapper
class sa(object):
@a
async def b(self, text):
print(text)
return False
n = ...
ответ дан 16 дек '20 в 13:37
gil9red
59k55 золотых знаков4040 серебряных знаков9090 бронзовых знаков
3
Вы можете попробовать использовать библиотеку nest_asyncio, добавив две строчки кода:
import nest_asyncio
nest_asyncio.apply()
Тогда ваш код будет выглядеть так:
import asyncio
import time
import nest_asyncio
nest_asyncio.apply()
async def waiter() -> None:
await cook('Паста', 8)
await cook('Салат Цезарь', 3)
await cook('Отбивные', 16)
...
2
На самом деле все оказалось просто:
def on_chat_msg(msg):
do_smth()
def cycle():
while True:
do_smth_else()
th = threading.Thread(target=cycle, args=[], daemon=True)
th.start()
2
Не только можете, но и должны. Создавать пул соединений для каждого запроса - это плохое решение. Но стоит учесть, что SQLAlchemy по умолчанию синхронная, а значит, что без дополнительных ухищрений весь ваш сервер становится синхронным. Вот как этот вопрос решает сам автор aiohttp.
ответ дан 19 дек '17 в 6:26
Sergey Gornostaev
64k66 золотых знаков4040 серебряных знаков9696 бронзовых знаков
2
Чтобы приостанавливать и снова запускать цикл из другого места кода, можно asyncio.Event() использовать:
#!/usr/bin/env python3
import asyncio
import itertools
import sys
async def restartable_loop(running):
for char in itertools.cycle(r'/|\-'): # heartbeat
print('\b' + char, flush=True, end='', file=sys.stderr)
if not running.is_set():...
2
import asyncio
import signal
ws_list = []
def shutdown():
# Отменяем все задачи
for task in asyncio.Task.all_tasks():
task.cancel()
async def consumer(condition):
while True:
try:
with await condition: # Захватываем condition
await condition.wait() # Ждём condition
print(ws_list[-1])...
ответ дан 5 мар '18 в 6:44
Sergey Gornostaev
64k66 золотых знаков4040 серебряных знаков9696 бронзовых знаков
2
Это будет немного сложновато, + не уверен что смогу все идеально описать и обосновать, но думаю это будет хорошим началом.
В код для ясности внесем кое-какие изменения:
async def my_task():
print(2, asyncio.all_tasks())
await asyncio.sleep(0.5)
print(4, asyncio.all_tasks())
async def go():
time = 0.2
asyncio.create_task(my_task())
...
Допускаются только превышающие минимальную длину ответы с наивысшим рейтингом, не являющиеся общими
Связанные метки
asyncio × 197python × 181
python-3.x × 71
aiohttp × 27
async-await × 21
async × 19
асинхронность × 13
aiogram × 13
многопоточность × 12
telegram-bot × 7
websocket × 7
python-3.6 × 6
django × 5
http × 5
сокет × 5
event-loop × 5
python-3.5 × 4
multiprocessing × 4
python-3.8 × 4
async-programming × 4
kivy × 3
discord-api × 3
telethon × 3
mysql × 2
windows × 2