Multithread sur une source de données (MySQL)

Bonjour,

J'ai besoin de réaliser un traitement sur chaque enregistrements résultants d'une requête SQL.
Pour accélérer ce traitement, je souhaite faire du multithread (il n'y a pas besoin d'attendre la fin du traitement de la première ligne résultante pour enchainer la deuxième).

Seulement, je ne vois pas trop comment gérer l'accès de plusieurs threads sur la même source de données.

Exemple : ma requête retourne 18 lignes et j'ai 2 threads
Je souhaite que le thread 1 accède à la première ligne et le thread 2 voit que l'accès à la première ligne est déjà occupé, alors il enchaine sur la ligne suivante (la deuxième).

Avez-vous une idée svp ?

Bonjour,
Je ne me souviens plus quel exemple, mais dans les exemples livrés avec windev, il y en a un sur les sémaphores qui permettent d'attendre la disponibilité d'un Thread.
Cordialement

Bon, je suis allé voir si je pouvais retrouver l'exemple, il s'agit de "Les threads (pool)".
je pense que vous pouvez adapter à votre cas en demandant un traitement pour chaque ligne, chaque traitement attendant une place dans le pool.

Yop. Moi quand je lis "J'ai besoin de réaliser un traitement sur chaque enregistrements résultants d'une requête SQL." je demande direct si tu ne peux pas faire faire ce traitement a une requête plutôt? Si tu veux modifier les enregistrements en base au final, peut être que c'est à la base de bosser, pas au code.

Citation:

---

Envoyé par kunnskap

Yop. Moi quand je lis "J'ai besoin de réaliser un traitement sur chaque enregistrements résultants d'une requête SQL." je demande direct si tu ne peux pas faire faire ce traitement a une requête plutôt? Si tu veux modifier les enregistrements en base au final, peut être que c'est à la base de bosser, pas au code.

---

Rien est modifié en base, c'est juste une lecture ;)

Bonjour,

La réponse sera la même : pourquoi exécuter 1000 fois une requête avec un id plutôt que d'en faire une avec les 1000 id ?

Bonjour,

Moi, ce que je comprends de la demande de matheous, c'est qu'il utilise le résultat de la requête pour traiter des données ailleurs (pas dans la base de données), traitement long pour lequel il souhaite faire appel à des threads (j'ai déjà eu à traiter ce genre de cas).

@ matheous
As-tu trouvé une solution correspondant à tes besoins ?

Dans ce cas, pourquoi ne pas faire un truc du genre :

Code:

---

1 2 3 4 5 6

i est entier = 1 POUR TOUT srcResReq ThreadExécute("Thread" + NumériqueVersChaine(i, "03d"), threadNormal, ProcThread, srcResReq) i++ Temporisation(5) // juste pour limiter un peu l'avalanche de threads. Est peut-être inutile... FIN

---

Très bourrin mais ça fait du thread :D

Utilises les tâches parallèles et avec TâcheParallèleParamètre tu peux fixer le nombre max de threads qui vont s'exécuter en même temps.
Tu récupères tes data que tu parcours et pour chaque ligne tu envoies à la tâche parallèle une variable de type Enregistrement.