mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-01-09 00:45:56 +00:00
Code Issues 1 Projects Releases Wiki Activity

Convert to GThreads

Browse source 
Original commit message from CVS:
Convert to GThreads
This commit is contained in:
David Schleef 2002-11-01 22:17:20 +00:00
parent 86fddd8349
commit d99b48b2e6
2 changed files with 21 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
tests/memchunk/gmemchunktest.c
View file

@ -41,15 +41,17 @@ run_test (void *threadid)
free_chunk (chunk);
}
pthread_exit(NULL);
g_thread_exit(NULL);
return NULL;
}
gint
main (gint argc, gchar *argv[])
{
pthread_t threads[MAX_THREADS];
int rc, t;
GThread *threads[MAX_THREADS];
GError *error;
int t;
gst_init (&argc, &argv);
@ -65,15 +67,16 @@ main (gint argc, gchar *argv[])
_lock = g_mutex_new ();
for(t=0; t < num_threads; t++) {
rc = pthread_create (&threads[t], NULL, run_test, (void *)t);
if (rc) {
printf ("ERROR: return code from pthread_create() is %d\n", rc);
printf ("Code %d= %s\n", rc, strerror(rc));
error = NULL;
threads[t] = g_thread_create (run_test, (void *)t, TRUE, &error);
if (error) {
printf ("ERROR: g_thread_create () is %s\n", error->message);
exit (-1);
}
}
printf ("main(): Created %d threads.\n", t);
pthread_exit (NULL);
g_thread_exit (NULL);
g_mem_chunk_info();
return 0;
}

18
tests/memchunk/gstmemchunktest.c
View file

@ -37,15 +37,17 @@ run_test (void *threadid)
free_chunk (chunk);
}
pthread_exit(NULL);
g_thread_exit(NULL);
return NULL;
}
gint
main (gint argc, gchar *argv[])
{
pthread_t threads[MAX_THREADS];
int rc, t;
GThread * threads[MAX_THREADS];
GError * error;
int t;
gst_init (&argc, &argv);
@ -60,17 +62,17 @@ main (gint argc, gchar *argv[])
_chunks = gst_mem_chunk_new ("test", 32, 32 * 16, G_ALLOC_AND_FREE);
for(t=0; t < num_threads; t++) {
rc = pthread_create (&threads[t], NULL, run_test, (void *)t);
if (rc) {
printf ("ERROR: return code from pthread_create() is %d\n", rc);
printf ("Code %d= %s\n", rc, strerror(rc));
error = NULL;
threads[t] = g_thread_create (run_test, (void *)t, TRUE, &error);
if (error) {
printf ("ERROR: g_thread_create() %s\n", error->message);
exit (-1);
}
}
printf ("main(): Created %d threads.\n", t);
for(t=0; t < num_threads; t++) {
pthread_join (threads[t], NULL);
g_thread_join (threads[t]);
}
g_mem_chunk_info();