Dans quelle situation nous avons besoin d'utiliser les " multiprocessing.Piscine.imap_unordered`?

À l'aide de pool.imap_unordered au lieu de pool.imap n'aura pas un grand effet sur le temps total d'exécution de votre code. Il pourrait être un peu plus rapide, mais pas trop.

Ce qu'elle peut faire, cependant, est de procéder à l'intervalle entre les valeurs disponibles dans vos itération de plus, même. C'est, si vous avez les opérations qui peuvent prendre très différentes quantités de temps (plutôt que de la cohérence de l' 0.01 secondes vous utilisiez dans votre exemple), imap_unordered permet de lisser les choses par le rendement plus rapide des valeurs calculées à l'avance, de façon plus lente des valeurs calculées. Le régulier imap retardera le rendement le plus rapide, jusqu'à ce que, après le ralentissement de celles à venir ont été calculés (mais cela ne veut pas retarder le processus de travail de passer à plus de calculs, juste le temps pour vous de voir).

Essayez de faire votre travail en fonction sommeil pour i*0.1 secondes, en déplaçant votre liste de saisie et d'impression i dans vos boucles. Vous serez en mesure de voir la différence entre les deux imap versions. Voici ma version (la main de la fonction et de la if __name__ == '__main__' standard est requis pour exécuter correctement sur Windows):

from multiprocessing import Pool
import time
import random

def work(i):
    time.sleep(0.1*i)
    return i

def main():
    p = Pool(4)
    nums = range(50)
    random.shuffle(nums)

    start = time.time()
    print 'Using imap'
    for i in p.imap(work, nums):
        print i
    print 'Time elapsed: %s' % (time.time() - start)

    start = time.time()
    print 'Using imap_unordered'
    for i in p.imap_unordered(work, nums):
        print i
    print 'Time elapsed: %s' % (time.time() - start)

if __name__ == "__main__":
    main()

La imap version de longues pauses, tandis que des valeurs comme l'49 sont traitées (en prenant 4,9 secondes), puis il va voler au-dessus d'un tas d'autres valeurs ont été calculées par les autres processus, alors que nous étions en attente de 49 à traiter). En revanche, la imap_unordered boucle sera généralement pas une pause presque aussi long à la fois. Il aura de plus en plus fréquentes, mais de plus courte pause, et sa sortie aura tendance à être plus lisse.