NK
Как я понял, сабпроцессы в asyncio не блокируют поток?
Size: a a a
2019 June 21
YL
ID:803370278
Как я понял, сабпроцессы в asyncio не блокируют поток?
ну при использовании asyncio.create_subprocess_shell - да, всё верно)
2019 June 23
B
всем привет, а асинк работает в потоке?) т.е. я создал поток через threading.Thread - а в нем асинк функция
или как лучше запускать нечто потока? и что есть тру годное, чтобы почитать про асинк в питоне
или как лучше запускать нечто потока? и что есть тру годное, чтобы почитать про асинк в питоне
YL
всем привет, а асинк работает в потоке?) т.е. я создал поток через threading.Thread - а в нем асинк функция
или как лучше запускать нечто потока? и что есть тру годное, чтобы почитать про асинк в питоне
или как лучше запускать нечто потока? и что есть тру годное, чтобы почитать про асинк в питоне
для начинающих асинхронный пайтон хорошо раскрывается в "Python. К вершинам мастерства" Лучано Рамальо, где-то с середины книги
🇧S
всем привет, а асинк работает в потоке?) т.е. я создал поток через threading.Thread - а в нем асинк функция
или как лучше запускать нечто потока? и что есть тру годное, чтобы почитать про асинк в питоне
или как лучше запускать нечто потока? и что есть тру годное, чтобы почитать про асинк в питоне
асинк функцию в любом случае нужно в ивент лупе запускать
YL
всем привет, а асинк работает в потоке?) т.е. я создал поток через threading.Thread - а в нем асинк функция
или как лучше запускать нечто потока? и что есть тру годное, чтобы почитать про асинк в питоне
или как лучше запускать нечто потока? и что есть тру годное, чтобы почитать про асинк в питоне
>т.е. я создал поток через threading.Thread - а в нем асинк функция
покажи что ты сделал, на минималистичном примере.
объясни зачем ты это сделал.
покажи что ты сделал, на минималистичном примере.
объясни зачем ты это сделал.
B
для начинающих асинхронный пайтон хорошо раскрывается в "Python. К вершинам мастерства" Лучано Рамальо, где-то с середины книги
сямба
B
>т.е. я создал поток через threading.Thread - а в нем асинк функция
покажи что ты сделал, на минималистичном примере.
объясни зачем ты это сделал.
покажи что ты сделал, на минималистичном примере.
объясни зачем ты это сделал.
я имел ввиду, типо такого:
async def lalala(arg1):
await func_tralala(arg1)
thread = Thread(target=lalala, args=(1,))
thread.start()B
это пример просто, что я имел ввиду
YL
нет, так не заработает, ты же можешь вставить свой пример в интерпретатор и убедиться в этом
B
нет, так не заработает, ты же можешь вставить свой пример в интерпретатор и убедиться в этом
а как это сделать то?
YL
а как это сделать то?
ты не объяснил что ты делаешь и с какой целью
B
ты не объяснил что ты делаешь и с какой целью
по сути, мне надо запустить 3 функции, разумеется 1 функция = 1 поток
на синке это выглядело бы так:
на синке это выглядело бы так:
def t(arg1):
print('t')
def a():
print('a')
def b(arg1):
print('b')
thread1 = Thread(target=t, args=(1,))
thread2 = Thread(target=a)
thread3 = Thread(target=b, args=(1,))
thread1.start()
thread2.start()
thread3.start()
B
сорри за простыню
YL
по сути, мне надо запустить 3 функции, разумеется 1 функция = 1 поток
на синке это выглядело бы так:
на синке это выглядело бы так:
def t(arg1):
print('t')
def a():
print('a')
def b(arg1):
print('b')
thread1 = Thread(target=t, args=(1,))
thread2 = Thread(target=a)
thread3 = Thread(target=b, args=(1,))
thread1.start()
thread2.start()
thread3.start()
import asyncio
async def smth_1():
print('smth_1')
return 1
async def smth_2():
print('smth_2')
return 2
async def smth_3():
print('smth_3')
return 3
if __name__ == '__main__':
coros = [smth_1(), smth_2(), smth_3()]
print(coros)
tasks_gather_coro = asyncio.gather(*coros)
print(tasks_gather_coro)
loop = asyncio.get_event_loop()
print('======\nstart running')
result = loop.run_until_complete(tasks_gather_coro)
print(result)
YL
вставь, запусти, попробуй разобраться
YL
а потом вернись и расскажи зачем ты хочешь объединить многопоточность и асинхронность в рамках одной программы
2019 June 25
s
import asyncio
async def smth_1():
print('smth_1')
return 1
async def smth_2():
print('smth_2')
return 2
async def smth_3():
print('smth_3')
return 3
if __name__ == '__main__':
coros = [smth_1(), smth_2(), smth_3()]
print(coros)
tasks_gather_coro = asyncio.gather(*coros)
print(tasks_gather_coro)
loop = asyncio.get_event_loop()
print('======\nstart running')
result = loop.run_until_complete(tasks_gather_coro)
print(result)
можно ещё
run = loop.run_until_complete
tasks = [loop.create_task(coro) for coro in coros]
[print(run(result)) for result in tasks]
run = loop.run_until_complete
tasks = [loop.create_task(coro) for coro in coros]
[print(run(result)) for result in tasks]
I
потому что они не будут использовать пул потоков/процессов
Используют
BG
Используют
Эм... нет?