Différences

Ci-dessous, les différences entre deux révisions de la page.

--- tech:notes_python_multithreading [2025/03/24 15:06] – créée - modification externe 127.0.0.1
+++ tech:notes_python_multithreading [2025/05/20 17:51] (Version actuelle) – Jean-Baptiste
@@ Ligne 12: / Ligne 12: @@
 * https://pypi.org/project/pygolang/
 * https://pypi.org/project/python-defer/
+Thread safe :
+* https://plainenglish.io/blog/thread-safety-in-python
+* https://jonbleiberg.medium.com/how-python-keeps-your-queues-thread-safe-4b66a2f3e692
 Nombre de CPU logiques
@@ Ligne 195: / Ligne 202: @@
 * Vous pouvez uniquement utiliser ''await'' dans les fonctions créées avec ''async def''
 * Une Coroutune déclarée avec ''async def'' ne peut être appelée que par
- ** ''await'' si le résultat doit être attendu
+  * ''await'' si le résultat doit être attendu
- ** ''create_task()'' (''asyncio.create_task()'' ou ''asyncio.TaskGroup'') pour ne pas attendre le résultat
+  * ''create_task()'' (''asyncio.create_task()'' ou ''asyncio.TaskGroup'') pour ne pas attendre le résultat
- ** ''asyncio.gather()''
+  * ''asyncio.gather()''
- ** ''asyncio.run()''
+  * ''asyncio.run()''
 *  "**Coroutine**" est juste un terme élaboré pour désigner ce qui est retourné par une fonction définie avec ''async def''. Python sait que c'est comme une fonction classique qui va démarrer à un moment et terminer à un autre, mais qu'elle peut aussi être mise en pause, du moment qu'il y a un ''await'' dans son contenu.
 * ''time.sleep()'' (ainsi que d'autres lib/fonction) n'est pas compatible avec ''asyncio''. A la place il faut utiliser ''asyncio.sleep()''
@@ Ligne 294: / Ligne 301: @@
 </code>
 Source : https://stackoverflow.com/questions/56318648/how-to-run-an-asyncio-task-without-awaiting
+Thread safe
+<code python>
+from collections import deque
+thread_safe_deque = deque()
+# Thread 1
+thread_safe_deque.append(1)
+# Thread 2
+element = thread_safe_deque.pop()
+</code>
+Source : https://www.cloudthat.com/resources/blog/writing-thread-safe-programs-in-python
+---------
+Source : nsclient ''NSCP-0.8.0-x64/scripts/python''
+''badapp.py''
+<code python>
+#! /usr/bin/env python3
+import threading
+class BadThread(threading.Thread):
+        id = -1
+        def __init__(self, id):
+                self.id = id
+                threading.Thread.__init__(self)
+        def run(self):
+                i = 0
+                while(True):
+                        i = i + 1
+                        if i > 100000:
+                                print('Processing: %d'%self.id)
+                                i = 0
+for x in range(1000):
+        BadThread(x).start()
+</code>