Improved the way threads are managed.

2 files changed, 103 insertions, 15 deletions

diff --git a/src/core/queue.c b/src/core/queue.c
index 4439e61..9323803 100644
--- a/src/core/queue.c
+++ b/src/core/queue.c
@@ -25,12 +25,19 @@
 
 
 #include <assert.h>
+#include <malloc.h>
 
 
 #include "global.h"
 
 
 
+/* Mémorisation des groupes de travail */
+static wgroup_id_t *_global_group_ids = NULL;
+static size_t _global_group_count = 0;
+G_LOCK_DEFINE_STATIC(_gg_mutex);
+
+
 /******************************************************************************
 *                                                                             *
 *  Paramètres  : -                                                            *
@@ -54,24 +61,24 @@ bool init_global_works(void)
     set_work_queue(queue);
 
 #ifndef NDEBUG
-    expected = g_work_queue_define_work_group(queue);
+    expected = setup_global_work_group();
     assert(expected == DEFAULT_WORK_GROUP);
 #else
-    g_work_queue_define_work_group(queue);
+    setup_global_work_group();
 #endif
 
 #ifndef NDEBUG
-    expected = g_work_queue_define_work_group(queue);
+    expected = setup_global_work_group();
     assert(expected == LOADING_WORK_GROUP);
 #else
-    g_work_queue_define_work_group(queue);
+    setup_global_work_group();
 #endif
 
 #ifndef NDEBUG
-    expected = g_work_queue_define_work_group(queue);
+    expected = setup_global_work_group();
     assert(expected == STORAGE_WORK_GROUP);
 #else
-    g_work_queue_define_work_group(queue);
+    setup_global_work_group();
 #endif
 
     return true;
@@ -83,6 +90,76 @@ bool init_global_works(void)
 *                                                                             *
 *  Paramètres  : -                                                            *
 *                                                                             *
+*  Description : Constitue un nouveau groupe de travail global.               *
+*                                                                             *
+*  Retour      : Nouvel identifiant unique d'un nouveau groupe de travail.    *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+wgroup_id_t setup_global_work_group(void)
+{
+    wgroup_id_t result;                     /* Valeur à retourner          */
+    GWorkQueue *queue;                      /* Singleton pour tâches       */
+
+    queue = get_work_queue();
+
+    result = g_work_queue_define_work_group(queue);
+
+    G_LOCK(_gg_mutex);
+
+    _global_group_ids = (wgroup_id_t *)realloc(_global_group_ids,
+                                               ++_global_group_count * sizeof(wgroup_id_t));
+
+    _global_group_ids[_global_group_count - 1] = result;
+
+    G_UNLOCK(_gg_mutex);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : count = quantité de threads à allouer.                       *
+*                                                                             *
+*  Description : Constitue un nouveau petit groupe de travail global.         *
+*                                                                             *
+*  Retour      : Nouvel identifiant unique d'un nouveau groupe de travail.    *
+*                                                                             *
+*  Remarques   : -                                                            *
+*                                                                             *
+******************************************************************************/
+
+wgroup_id_t setup_tiny_global_work_group(guint count)
+{
+    wgroup_id_t result;                     /* Valeur à retourner          */
+    GWorkQueue *queue;                      /* Singleton pour tâches       */
+
+    queue = get_work_queue();
+
+    result = g_work_queue_define_tiny_work_group(queue, count);
+
+    G_LOCK(_gg_mutex);
+
+    _global_group_ids = (wgroup_id_t *)realloc(_global_group_ids,
+                                               ++_global_group_count * sizeof(wgroup_id_t));
+
+    _global_group_ids[_global_group_count - 1] = result;
+
+    G_UNLOCK(_gg_mutex);
+
+    return result;
+
+}
+
+
+/******************************************************************************
+*                                                                             *
+*  Paramètres  : -                                                            *
+*                                                                             *
 *  Description : Supprime les mécanismes de traitements parallèles.           *
 *                                                                             *
 *  Retour      : -                                                            *
@@ -95,6 +172,16 @@ void exit_global_works(void)
 {
     GWorkQueue *queue;                      /* Singleton pour tâches       */
 
+    G_LOCK(_gg_mutex);
+
+    if (_global_group_ids != NULL)
+        free(_global_group_ids);
+
+    _global_group_ids = NULL;
+    _global_group_count = 0;
+
+    G_UNLOCK(_gg_mutex);
+
     queue = get_work_queue();
 
     g_object_unref(G_OBJECT(queue));
@@ -118,14 +205,8 @@ void wait_for_all_global_works(void)
 {
     GWorkQueue *queue;                      /* Singleton pour tâches       */
 
-    static const wgroup_id_t group_ids[GLOBAL_WORK_GROUPS_COUNT] = {
-        DEFAULT_WORK_GROUP,
-        LOADING_WORK_GROUP,
-        STORAGE_WORK_GROUP
-    };
-
     queue = get_work_queue();
 
-    g_work_queue_wait_for_all_completions(queue, group_ids, GLOBAL_WORK_GROUPS_COUNT);
+    g_work_queue_wait_for_all_completions(queue, _global_group_ids, _global_group_count);
 
 }
diff --git a/src/core/queue.h b/src/core/queue.h
index a1b82f2..8f1625e 100644
--- a/src/core/queue.h
+++ b/src/core/queue.h
@@ -28,6 +28,9 @@
 #include <stdbool.h>
 
 
+#include "../glibext/delayed.h"
+
+
 
 /**
  * Groupes d'exécution principaux.
@@ -37,12 +40,16 @@
 #define LOADING_WORK_GROUP 1
 #define STORAGE_WORK_GROUP 2
 
-#define GLOBAL_WORK_GROUPS_COUNT 3
-
 
 /* Met en place les mécanismes de traitements parallèles. */
 bool init_global_works(void);
 
+/* Constitue un nouveau groupe de travail global. */
+wgroup_id_t setup_global_work_group(void);
+
+/* Constitue un nouveau petit groupe de travail global. */
+wgroup_id_t setup_tiny_global_work_group(guint);
+
 /* Supprime les mécanismes de traitements parallèles. */
 void exit_global_works(void);