diff --git a/tests/benchmarks/gstbufferstress.c b/tests/benchmarks/gstbufferstress.c
index e3f2912a3e..e7ec274ebd 100644
--- a/tests/benchmarks/gstbufferstress.c
+++ b/tests/benchmarks/gstbufferstress.c
@@ -20,6 +20,7 @@
 #include <stdio.h>
 #include <stdlib.h>
 #include <gst/gst.h>
+#include "gst/glib-compat-private.h"
 
 #define MAX_THREADS  1000
 
@@ -95,7 +96,12 @@ main (gint argc, gchar * argv[])
   for (t = 0; t < num_threads; t++) {
     GError *error = NULL;
 
+#if !GLIB_CHECK_VERSION (2, 31, 0)
     threads[t] = g_thread_create (run_test, GINT_TO_POINTER (t), TRUE, &error);
+#else
+    threads[t] = g_thread_try_new ("bufferstresstest", run_test,
+        GINT_TO_POINTER (t), &error);
+#endif
     if (error) {
       printf ("ERROR: g_thread_create() %s\n", error->message);
       exit (-1);
diff --git a/tests/benchmarks/gstclockstress.c b/tests/benchmarks/gstclockstress.c
index b0f721b3d5..60895d92b0 100644
--- a/tests/benchmarks/gstclockstress.c
+++ b/tests/benchmarks/gstclockstress.c
@@ -65,7 +65,12 @@ main (gint argc, gchar * argv[])
   for (t = 0; t < num_threads; t++) {
     GError *error = NULL;
 
+#if !GLIB_CHECK_VERSION (2, 31, 0)
     threads[t] = g_thread_create (run_test, sysclock, TRUE, &error);
+#else
+    threads[t] = g_thread_try_new ("clockstresstest", run_test,
+        sysclock, &error);
+#endif
     if (error) {
       printf ("ERROR: g_thread_create() %s\n", error->message);
       exit (-1);
diff --git a/tests/benchmarks/gstpollstress.c b/tests/benchmarks/gstpollstress.c
index bf0d548fd3..b384f9554f 100644
--- a/tests/benchmarks/gstpollstress.c
+++ b/tests/benchmarks/gstpollstress.c
@@ -21,6 +21,7 @@
 #include <stdio.h>
 #include <stdlib.h>
 #include <gst/gst.h>
+#include "gst/glib-compat-private.h"
 
 static GstPoll *set;
 static GList *fds = NULL;
@@ -159,7 +160,12 @@ main (gint argc, gchar * argv[])
   for (t = 0; t < num_threads; t++) {
     GError *error = NULL;
 
+#if !GLIB_CHECK_VERSION (2, 31, 0)
     threads[t] = g_thread_create (run_test, GINT_TO_POINTER (t), TRUE, &error);
+#else
+    threads[t] = g_thread_try_new ("pollstresstest", run_test,
+        GINT_TO_POINTER (t), &error);
+#endif
     if (error) {
       printf ("ERROR: g_thread_create() %s\n", error->message);
       exit (-1);