New File implementing an asynchronous queue to be used for asynchronous

2000-04-28  Sebastian Wilhelmi  <wilhelmi@ira.uka.de>

	* gasyncqueue.c: New File implementing an asynchronous queue to be
	used for asynchronous inter-thread communication.

	* gthreadpool.c: New File implementing a thread pool to be used
	for distributing work among several threads.

	* glib.h: Added the type and function declarations for these two
	types.

	* tests/threadpool-test.c: New File implementing a test for the
	thread pool. This also checks the asynchronous queue underlying
	the thread pool.

	* tests/Makefile.am: Changed accordingly.

1 files changed, 57 insertions, 0 deletions

diff --git a/tests/threadpool-test.c b/tests/threadpool-test.c
new file mode 100644
index 000000000..9044e4bbd
--- /dev/null
+++ b/tests/threadpool-test.c
@@ -0,0 +1,57 @@
+#include <glib.h>
+
+#define RUNS 100
+
+G_LOCK_DEFINE_STATIC (thread_counter);
+gulong abs_thread_counter;
+gulong running_thread_counter;
+
+void
+thread_pool_func (gpointer a, gpointer b)
+{
+  G_LOCK (thread_counter);
+  abs_thread_counter++;
+  running_thread_counter++;
+  G_UNLOCK (thread_counter);
+
+  g_usleep (g_random_int_range (0, 4000));
+
+  G_LOCK (thread_counter);
+  running_thread_counter--;
+  G_UNLOCK (thread_counter);
+}
+
+int 
+main (int   argc,
+      char *argv[])
+{
+  GThreadPool *pool1, *pool2, *pool3;
+  guint i;
+  /* Only run the test, if threads are enabled and a default thread
+     implementation is available */
+#if defined(G_THREADS_ENABLED) && ! defined(G_THREADS_IMPL_NONE)
+  g_thread_init (NULL);
+  
+  pool1 = g_thread_pool_new (thread_pool_func, 3, 0, FALSE, 
+                            G_THREAD_PRIORITY_NORMAL, FALSE, NULL);
+  pool2 = g_thread_pool_new (thread_pool_func, 5, 0, FALSE, 
+			     G_THREAD_PRIORITY_LOW, FALSE, NULL);
+  pool3 = g_thread_pool_new (thread_pool_func, 7, 0, FALSE, 
+                             G_THREAD_PRIORITY_LOW, TRUE, NULL);
+
+  for (i = 0; i < RUNS; i++)
+    {
+      g_thread_pool_push (pool1, GUINT_TO_POINTER (1));
+      g_thread_pool_push (pool2, GUINT_TO_POINTER (1));
+      g_thread_pool_push (pool3, GUINT_TO_POINTER (1));
+    } 
+  
+  g_thread_pool_free (pool1, FALSE, TRUE);
+  g_thread_pool_free (pool2, FALSE, TRUE);
+  g_thread_pool_free (pool3, FALSE, TRUE);
+
+  g_assert (RUNS * 3 == abs_thread_counter);
+  g_assert (running_thread_counter == 0);  
+#endif
+  return 0;
+}