#include #include #ifdef G_OS_UNIX #include #endif #define G_TYPE_TEST (my_test_get_type ()) #define MY_TEST(test) (G_TYPE_CHECK_INSTANCE_CAST ((test), G_TYPE_TEST, GTest)) #define MY_IS_TEST(test) (G_TYPE_CHECK_INSTANCE_TYPE ((test), G_TYPE_TEST)) #define MY_TEST_CLASS(tclass) (G_TYPE_CHECK_CLASS_CAST ((tclass), G_TYPE_TEST, GTestClass)) #define MY_IS_TEST_CLASS(tclass) (G_TYPE_CHECK_CLASS_TYPE ((tclass), G_TYPE_TEST)) #define MY_TEST_GET_CLASS(test) (G_TYPE_INSTANCE_GET_CLASS ((test), G_TYPE_TEST, GTestClass)) typedef struct _GTest GTest; typedef struct _GTestClass GTestClass; struct _GTest { GObject object; }; struct _GTestClass { GObjectClass parent_class; }; static GType my_test_get_type (void); static volatile gboolean stopping; static void my_test_class_init (GTestClass * klass); static void my_test_init (GTest * test); static void my_test_dispose (GObject * object); static GObjectClass *parent_class = NULL; static GType my_test_get_type (void) { static GType test_type = 0; if (!test_type) { const GTypeInfo test_info = { sizeof (GTestClass), NULL, NULL, (GClassInitFunc) my_test_class_init, NULL, NULL, sizeof (GTest), 0, (GInstanceInitFunc) my_test_init, NULL }; test_type = g_type_register_static (G_TYPE_OBJECT, "GTest", &test_info, 0); } return test_type; } static void my_test_class_init (GTestClass * klass) { GObjectClass *gobject_class; gobject_class = (GObjectClass *) klass; parent_class = g_type_class_ref (G_TYPE_OBJECT); gobject_class->dispose = my_test_dispose; } static void my_test_init (GTest * test) { g_print ("init %p\n", test); } static void my_test_dispose (GObject * object) { GTest *test; test = MY_TEST (object); g_print ("dispose %p!\n", test); G_OBJECT_CLASS (parent_class)->dispose (object); } static void my_test_do_refcount (GTest * test) { g_object_ref (test); g_object_unref (test); } static gpointer run_thread (GTest * test) { gint i = 1; while (!stopping) { my_test_do_refcount (test); if ((i++ % 10000) == 0) { g_print ("."); g_thread_yield(); /* force context switch */ } } return NULL; } int main (int argc, char **argv) { gint i; GTest *test1, *test2; GArray *test_threads; const guint n_threads = 5; g_print ("START: %s\n", argv[0]); g_log_set_always_fatal (G_LOG_LEVEL_WARNING | G_LOG_LEVEL_CRITICAL | g_log_set_always_fatal (G_LOG_FATAL_MASK)); test1 = g_object_new (G_TYPE_TEST, NULL); test2 = g_object_new (G_TYPE_TEST, NULL); test_threads = g_array_new (FALSE, FALSE, sizeof (GThread *)); stopping = FALSE; for (i = 0; i < n_threads; i++) { GThread *thread; thread = g_thread_create ((GThreadFunc) run_thread, test1, TRUE, NULL); g_array_append_val (test_threads, thread); thread = g_thread_create ((GThreadFunc) run_thread, test2, TRUE, NULL); g_array_append_val (test_threads, thread); } g_usleep (5000000); stopping = TRUE; g_print ("\nstopping\n"); /* join all threads */ for (i = 0; i < 2 * n_threads; i++) { GThread *thread; thread = g_array_index (test_threads, GThread *, i); g_thread_join (thread); } g_object_unref (test1); g_object_unref (test2); g_print ("stopped\n"); return 0; }