luc14n0/glib
1
0
Fork 0
mirror of https://gitlab.gnome.org/GNOME/glib.git synced 2024-11-04 16:36:17 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add a non-trivial GRecMutex test

Browse Source 
Adapted from the corresponding GMutex test.
This commit is contained in:
Matthias Clasen 2011-09-23 07:14:13 -04:00
parent de39df9dc1
commit 0a9885ebd8
1 changed files with 86 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

86
glib/tests/rec-mutex.c
View File

@ -64,6 +64,91 @@ test_rec_mutex3 (void)
g_rec_mutex_clear (&mutex);
}
#define LOCKS 48
#define ITERATIONS 10000
#define THREADS 100
GThread *owners[LOCKS];
GRecMutex locks[LOCKS];
static void
acquire (gint nr)
{
GThread *self;
self = g_thread_self ();
if (owners[nr] != NULL && owners[nr] != self)
{
if (g_test_verbose ())
g_print ("thread %p going to block on lock %d\n", self, nr);
}
g_rec_mutex_lock (&locks[nr]);
g_assert (owners[nr] == NULL); /* hopefully nobody else is here */
owners[nr] = self;
/* let some other threads try to ruin our day */
g_thread_yield ();
g_thread_yield ();
g_assert (owners[nr] == self); /* hopefully this is still us... */
g_rec_mutex_lock (&locks[nr]); /* we're recursive, after all */
g_assert (owners[nr] == self); /* hopefully this is still us... */
g_rec_mutex_unlock (&locks[nr]);
g_thread_yield ();
g_thread_yield ();
g_assert (owners[nr] == self); /* hopefully this is still us... */
owners[nr] = NULL; /* make way for the next guy */
g_rec_mutex_unlock (&locks[nr]);
}
static gpointer
thread_func (gpointer data)
{
gint i;
GRand *rand;
rand = g_rand_new ();
for (i = 0; i < ITERATIONS; i++)
acquire (g_rand_int_range (rand, 0, LOCKS));
g_rand_free (rand);
return NULL;
}
static void
test_rec_mutex4 (void)
{
gint i;
GThread *threads[THREADS];
for (i = 0; i < LOCKS; i++)
g_rec_mutex_init (&locks[i]);
for (i = 0; i < THREADS; i++)
threads[i] = g_thread_create (thread_func, NULL, TRUE, NULL);
for (i = 0; i < THREADS; i++)
g_thread_join (threads[i]);
for (i = 0; i < LOCKS; i++)
g_rec_mutex_clear (&locks[i]);
for (i = 0; i < LOCKS; i++)
g_assert (owners[i] == NULL);
}
int
main (int argc, char *argv[])
@ -73,6 +158,7 @@ main (int argc, char *argv[])
g_test_add_func ("/thread/rec-mutex1", test_rec_mutex1);
g_test_add_func ("/thread/rec-mutex2", test_rec_mutex2);
g_test_add_func ("/thread/rec-mutex3", test_rec_mutex3);
g_test_add_func ("/thread/rec-mutex4", test_rec_mutex4);
return g_test_run ();
}