google app engine - Асинхронные блоки кода? питон

Question

Поэтому у меня есть некоторый код, который функционирует что-то вроде этого общего кода:

for blah in blahs: 
    blah.take_forever() 

for blah2 in blah2s: 
    vars = blah2.take_forever() 
    for var in vars: 
    var.also_take_forever() 

Я хочу что-то, что такие функции, как в асинхронном, такие как

async_start_blah2_loop_then_do_someting_else() 

do_the_first_blah_loop() 

gather_results_and_send_them_out() 

Однако, я не с помощью хранилищу или urlfetch для этого, так что другие варианты ускорят этот процесс?

"

map_async(callback, pass_batch_into_callback=None, merge_future=None, **q_options) 
Asynchronously map a callback function or tasklet over the query results. This is the asynchronous version of map(). 

"

, кажется, относятся только к DATASTORE запросов.

Предложения?

Answer 1

Вы можете использовать собственный модуль threading Python в App Engine для асинхронного выполнения функций (см. threading.Thread). Это также отлично работает на автоматических масштабированных экземплярах, поскольку использует «зеленые» потоки вместо потоков ОС.

def blahFunc(): 
    for blah in blahs: 
    blah.take_forever() 

def blah2Func(): 
    for blah2 in blah2s: 
    vars = blah2.take_forever() 
    for var in vars: 
     var.also_take_forever() 

# Execute both loops 'at the same time' 
background = threading.Thread(target=blah2Func) 
background.start() 
blah1Func() 

Обратите внимание, что вы не обязательно получить любую скорость от этого (я предполагаю, что ваш был надуманный пример для простоты), как запрос все еще выполняет внутри одной и той же «реальной» потоком операционной системы, но это полезно, если вам необходимо избегать блокировки при длительной работе.

Если вы действительно долго выполняющиеся задачи, которые, возможно, придется работать дольше, чем запрос лучшим решением является использование Task Queues.