Problème avec ThreadPool (multiprocessing)

Bonjour,

J'ai un soucis avec mon programme...Ce que je voudrais faire c'est télécharger plusieurs fichiers en même temps, donc utiliser les threads

Dans ma classe, j'importe le module qui va bien :

Code:

---

from multiprocessing.pool import ThreadPool

---

dans l'init de ma classe :

Code:

---

self.threadPool = ThreadPool(4)

---

Sur le click du bouton "Start", je met ceci :

Code:

---

1 2 3

print("apply_async 1") self.threadPool.apply_async(self.downloadObjs[link].download()) print("apply_async 2")

---

La fonction download de mon objet :

Code:

---

1 2 3

def download(self): time.sleep(10) return

---

Console :

Code:

---

1 2	apply_async 1 apply_async 2

---

Le problème c'est que dans mon cas, l'appel à apply_aync n'est pas asynchrone, mais synchrone. C'est à dire que dans ma console "apply_async 2" est affiché 10 secondes après "apply_async 1"....


Question subsidiaire :
Pour faire ce que je veux faire, est-ce qu'il ne faut pas mieux que j'utlise plutôt threading.Thread ? Je trouvais qu'un pool était plus pratique pour pouvoir paramétrer facilement le nombre de téléchargements simutanés...


Quelqu'un pourrait m'aider svp ?

Salut,

Citation:

---

Envoyé par bombseb

Le problème c'est que dans mon cas, l'appel à apply_aync n'est pas asynchrone, mais synchrone. C'est à dire que dans ma console "apply_async 2" est affiché 10 secondes après "apply_async 1"....

---

Le soucis est surtout que vous n'avez pas encore compris la différence entre "passer une fonction en paramètre" et "passer le retour de la fonction en paramètre".

Citation:

---

Envoyé par bombseb

Pour faire ce que je veux faire, est-ce qu'il ne faut pas mieux que j'utlise plutôt threading.Thread ? Je trouvais qu'un pool était plus pratique pour pouvoir paramétrer facilement le nombre de téléchargements simutanés...

---

Le plus simple sera d'utiliser concurrent.futures qui vous permettrait de passer d'un pool de Threads à un pool de Process sans rien changer et voir ce que çà donne côté utilisation des ressources et performances.

- W

Citation:

---

Le soucis est surtout que vous n'avez pas encore compris la différence entre "passer une fonction en paramètre" et "passer le retour de la fonction en paramètre".

---

Le soucis c'est surtout la faute d'inattention qui m'a fait écrire ca :

Code:

---

self.threadPool.apply_async(self.downloadObjs[link].download())

---

au lieu de ca :

Code:

---

self.threadPool.apply_async(self.downloadObjs[link].download)

---

Je sais très bien ce qu'est la différence entre "passer une fonction en paramètre" et "passer le retour de la fonction en paramètre".

Citation:

---

Le plus simple sera d'utiliser concurrent.futures qui vous permettrait de passer d'un pool de Threads à un pool de Process sans rien changer et voir ce que çà donne côté utilisation des ressources et performances.

---

Merci pour ton aide je vais regarder ca...