Changes between Version 10 and Version 11 of AS6-TME-B7

Timestamp:

Apr 11, 2022, 8:28:07 PM (4 years ago)

Author:

franck

Comment:

--

AS6-TME-B7

@@ -171 +171 @@
 Une barrière de synchronisation est utilisée pour synchroniser les étapes de calculs réalisés par plusieurs threads. Supposons que l'on souhaite exécuter deux threads en parallèle et que l'on veuille attendre que les deux aient terminé leur travail avant de recommencer un travail. Il faut que les deux threads se donnent rendez-vous à la fin de leur calcul.
 
+{{{#!c
+/*------------------------------------------------------------------------*\
+   _     ___    __
+  | |__ /'v'\  / /      \date        2022-04-11
+  | / /(     )/ _ \     \copyright   2021-2022 Sorbonne University
+  |_\_\ x___x \___/                  https://opensource.org/licenses/MIT
+
+\*------------------------------------------------------------------------*/
+
+#include <libc.h>
+#include <thread.h>
+
+#define DELAY(n) for(int i=n;i--;) __asm__("nop"); 
+
+struct arg_s {                 // structure pour passer des args aux threads
+    int delay;                 // délai qui simule une durée de calcul 
+    char *message;             // chaine de caractères
+};
+
+thread_t t0, t1;               // 2 threads
+struct arg_s a0, a1;           // les arguments des threads      
+thread_barrier_t barrier;      // 1 barrière
+
+void * t0_fun (void * arg)     // thread qui sera instantié deux fois
+{
+    struct arg_s * a = arg;
+    while (1) {                           // faire toujours
+        fprintf (1, "%s\n", a->message);  //   afficher un message
+        DELAY (a->delay);                 //   calcul (il faudrait un random)
+        thread_barrier_wait (&barrier);   //   attendre l'autre instance
+    };
+}
+
+int main (void)
+{
+    thread_barrier_init (&barrier, 2);    // Créer une barrière pour 2
+
+    a0.delay = 500000;                    // args premier thread
+    a0.message = "bonjour";
+
+    a1.delay = 2000000;                   // args deuxième thread
+    a1.message = "salut";
+
+    thread_create (&t0, t0_fun, &a0);     // démarrer premier thread
+    thread_create (&t0, t0_fun, &a1);     // démarrer deuxieme thread
+
+    for (int i = 0;i<3; i++) {            // main() bosse de son coté
+        fprintf (0, "[%d] app is alive (%d)\n", clock(), i);
+        DELAY(100000);
+    }
+
+    void * trash;     
+    thread_join (t1, &trash);
+    thread_join (t0, &trash);
+    return 0;
+}
+}}}
+