compiti di esecuzione in parallelo in pitone

Question

Sto usando Python 2.7, ho un codice che assomiglia a questo:

task1() 
task2() 
task3() 
dependent1() 

task4() 
task5() 
task6() 
dependent2() 

dependent3() 

Le uniche dipendenze qui sono i seguenti: dependent1 deve attendere tasks1-3, dependent2 esigenze attendere le attività 4-6 e dipendente3 deve attendere le dipendenze1-2 ... Quanto segue dovrebbe essere corretto: eseguire prima tutte le 6 attività in parallelo, quindi le prime due dipendenti in parallelo .. quindi la dipendente finale

Preferisco avere quante più attività possibile in parallelo, ho cercato su google per alcuni moduli ma speravo di evitare le librerie esterne e non sono sicuro di come La tecnica ue-Thread può risolvere il mio problema (forse qualcuno può raccomandare una buona risorsa?)

Answer 1

La classe integrata threading.Thread offre tutto ciò che serve: start per iniziare una nuova discussione e join per attendere la fine di una discussione.

import threading 

def task1(): 
    pass 
def task2(): 
    pass 
def task3(): 
    pass 
def task4(): 
    pass 
def task5(): 
    pass 
def task6(): 
    pass 

def dep1(): 
    t1 = threading.Thread(target=task1) 
    t2 = threading.Thread(target=task2) 
    t3 = threading.Thread(target=task3) 

    t1.start() 
    t2.start() 
    t3.start() 

    t1.join() 
    t2.join() 
    t3.join() 

def dep2(): 
    t4 = threading.Thread(target=task4) 
    t5 = threading.Thread(target=task5) 

    t4.start() 
    t5.start() 

    t4.join() 
    t5.join() 

def dep3(): 
    d1 = threading.Thread(target=dep1) 
    d2 = threading.Thread(target=dep2) 

    d1.start() 
    d2.start() 

    d1.join() 
    d2.join() 

d3 = threading.Thread(target=dep3) 
d3.start() 
d3.join() 

alternativa ad aderire è possibile utilizzare Queue.join per aspettare la fine discussioni.

Answer 2

Vedere Gevent.

Esempio di utilizzo:

import gevent 
from gevent import socket 

def destination(jobs): 
    gevent.joinall(jobs, timeout=2) 
    print [job.value for job in jobs] 

def task1(): 
    return gevent.spawn(socket.gethostbyname, 'www.google.com') 

def task2(): 
    return gevent.spawn(socket.gethostbyname, 'www.example.com') 

def task3(): 
    return gevent.spawn(socket.gethostbyname, 'www.python.org') 

jobs = [] 
jobs.append(task1()) 
jobs.append(task2()) 
jobs.append(task3()) 
destination(jobs) 

Speranza, questo è quello che state cercando.