From ced030fc2263f05c3d3a7fddd8ba02406e24e7dd Mon Sep 17 00:00:00 2001
From: Jean Sirmai <sirmai@wanadoo.fr>
Date: Tue, 30 Mar 2021 15:09:29 +0000
Subject: [PATCH] a first scheme

---
 Concurrent Programming | 35 +++++++++++++++++++++++++++++++++++
 1 file changed, 35 insertions(+)

diff --git a/Concurrent Programming b/Concurrent Programming
index 275c8fa..2bd2669 100644
--- a/Concurrent Programming	
+++ b/Concurrent Programming	
@@ -1,3 +1,36 @@
+import threading
+from datetime import timedelta
+from datetime import datetime
+import random
+import time
+
+def local_worker(coord, id):
+    start = datetime.now().timestamp()
+    val = random.randint(1,1000)
+    time.sleep(val / 1000)
+    prev = space[coord]
+    next = space[coord] = 10 + val % 89
+    print('{}       on [{}] : {} > {}    by local thread n°{:>3}     {!s:.4}'.format(
+                                space,
+                                coord,
+                                prev,
+                                next,
+                                str(id),
+                                datetime.now().timestamp() - start
+                                )
+         )
+
+from threading import Thread
+space = []
+for i in range(0,10):
+    space.append(random.randint(10,99))
+print(space,'   <  initialglobal state')
+for k in range (1,20):
+    t = Thread(target=local_worker, args=(random.randint(0,len(space) - 1), k))
+    t.start()
+
+
+"""
     Le **scheduler**, ou processus principal, effectue un calcul sur l'**état global**.
 Pour cela, il génère des threads de calcul locaux ou '**local_workers**'
 auxquels il confie une partie de l'état global.
@@ -26,4 +59,6 @@ Il délègue à la **CLI** les fonctions de communications avec les modules pér
  + sinon arrêt de cette recherche en un temps fini
  
  3. mesures / recueil des commandes / retour d'information
+ 
+ """