Как сделать async в python?

Question

Существует функция, которая должна спать 10 секунд. Но в то же время я не хочу, чтобы он блокировал мою основную функцию. Как с этим бороться? Я пытаюсь сделать так. Однако он все еще блокирует мою основную функцию.

def tester(): 
    pool.size=2; 
    pool=multiprocessing.Pool(pool_size); 
    pool.apply_async(send_mail, args=("test",)); 
    pool.close(); 
    pool.join(); 
    print "email is done"; 

Основная функция вызовет эту функцию.

Answer 1

pool.join();

- ваш блокиратор. удалите его, чтобы он не блокировался.

https://docs.python.org/2/library/multiprocessing.html#multiprocessing.Process.join

EDIT:

import threading 

print "start" 
th = threading.Thread(target=tester) 
th.daemon = False 
print "thread start" 
th.start() 
print "executing other code" 

Answer 2

Не уверен, почему вы используете бассейн. Вы создаете 2 подпроцесса для отправки одного электронного письма? Как насчет того, чтобы просто создать единственный процесс. Следующее должно начать вас. (Я поставил «сон (30)», где вы на самом деле назвать send_mail)

from multiprocessing import Process, Queue 
from time import sleep 

def wrap_send_email(q, msg): 
    try: 
     sleep(30) 
     q.put([ msg, 'mail sent sucessfully']) 
    except: 
     q.put([ msg, 'mail not sent successfully']) 


def test(): 
    q = Queue() 
    p = Process(target=wrap_send_email, args=(q, 'test message')) 
    p.start() 
    while p.is_alive(): 
     print("Doing stuff while the other process is working.") 
     sleep(5) 
    print(q.get()) 
    p.join()