1
0
mirror of https://gitlab.gnome.org/GNOME/glib.git synced 2025-07-29 13:23:31 +02:00
Files
build
docs
gio
glib
gmodule
gobject
gthread
m4macros
po
tests
collate
gobject
refcount
.gitignore
Makefile.am
assert-msg-test.c
assert-msg-test.gdb
asyncqueue-test.c
atomic-test.c
bit-test.c
casefold.txt
casemap.txt
child-test.c
completion-test.c
cxx-test.C
datetime.c
dirname-test.c
env-test.c
file-test.c
gen-casefold-txt.pl
gen-casemap-txt.pl
gio-ls.c
gio-test.c
iochannel-test-infile
iochannel-test.c
libmoduletestplugin_a.c
libmoduletestplugin_b.c
mainloop-test.c
makefile.msc.in
mapping-test.c
memchunks.c
module-test.c
onceinit.c
qsort-test.c
relation-test.c
run-assert-msg-test.sh
run-collate-tests.sh
slice-color.c
slice-concurrent.c
slice-test.c
slice-threadinit.c
sources.c
spawn-test-win32-gui.c
spawn-test.c
testgdate.c
testgdateparser.c
testglib.c
thread-test.c
threadpool-test.c
timeloop-basic.c
timeloop.c
type-test.c
unicode-caseconv.c
unicode-collate.c
unicode-encoding.c
unicode-normalize.c
utf8.txt
.dir-locals.el
.gitignore
AUTHORS
COPYING
ChangeLog.pre-1-2
ChangeLog.pre-2-0
ChangeLog.pre-2-10
ChangeLog.pre-2-12
ChangeLog.pre-2-14
ChangeLog.pre-2-16
ChangeLog.pre-2-18
ChangeLog.pre-2-2
ChangeLog.pre-2-20
ChangeLog.pre-2-4
ChangeLog.pre-2-6
ChangeLog.pre-2-8
HACKING
INSTALL.in
Makefile.am
NEWS
NEWS.pre-1-3
README.commits
README.in
README.rationale
README.win32
acglib.m4
acinclude.m4
autogen.sh
check-abis.sh
config.h.win32.in
configure.ac
gio-2.0.pc.in
gio-unix-2.0.pc.in
gio-windows-2.0.pc.in
glib-2.0.pc.in
glib-gettextize.in
glib-tap.mk
glib-zip.in
glib.doap
glib.mk
gmodule-2.0.pc.in
gmodule-export-2.0.pc.in
gmodule-no-export-2.0.pc.in
gobject-2.0.pc.in
gthread-2.0.pc.in
makefile.msc
msvc_recommended_pragmas.h
sanity_check
tap-driver.sh
tap-test
win32-fixup.pl
glib/tests/sources.c
2014-01-31 14:31:55 +01:00

186 lines
5.0 KiB
C

/* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, see <http://www.gnu.org/licenses/>.
*
* Copyright 2012 Red Hat, Inc
*/
#undef G_DISABLE_ASSERT
#undef G_LOG_DOMAIN
#include <glib.h>
#define NSOURCES 50000
static gboolean
callback (gpointer user_data)
{
g_assert_not_reached ();
return FALSE;
}
static void
shuffle (GSource **sources, int num)
{
int i, a, b;
GSource *tmp;
for (i = 0; i < num * 10; i++)
{
a = g_random_int_range (0, num);
b = g_random_int_range (0, num);
tmp = sources[a];
sources[a] = sources[b];
sources[b] = tmp;
}
}
static void
thread_pool_attach_func (gpointer data,
gpointer user_data)
{
GMainContext *context = user_data;
GSource *source = data;
g_source_attach (source, context);
g_source_unref (source);
}
static void
thread_pool_destroy_func (gpointer data,
gpointer user_data)
{
GSource *source = data;
g_source_destroy (source);
}
int
main (int argc, char **argv)
{
int i;
gint64 start;
gint64 end;
GMainContext *context;
GSource **sources;
GThreadPool *pool;
GError *error = NULL;
context = g_main_context_default ();
sources = g_new0 (GSource *, NSOURCES);
start = g_get_monotonic_time ();
for (i = 0; i < NSOURCES; i++)
{
sources[i] = g_idle_source_new ();
g_source_set_callback (sources[i], callback, NULL, NULL);
g_source_attach (sources[i], context);
}
end = g_get_monotonic_time ();
g_print ("Add same-priority sources: %" G_GINT64_FORMAT "\n",
(end - start) / 1000);
#ifdef SLOW
start = g_get_monotonic_time ();
for (i = 0; i < NSOURCES; i++)
g_assert (sources[i] == g_main_context_find_source_by_id (context, g_source_get_id (sources[i])));
end = g_get_monotonic_time ();
g_print ("Find each source: %" G_GINT64_FORMAT "\n",
(end - start) / 1000);
#endif
shuffle (sources, NSOURCES);
start = g_get_monotonic_time ();
for (i = 0; i < NSOURCES; i++)
{
g_source_destroy (sources[i]);
g_source_unref (sources[i]);
}
end = g_get_monotonic_time ();
g_print ("Remove in random order: %" G_GINT64_FORMAT "\n",
(end - start) / 1000);
/* Make sure they really did get removed */
g_main_context_iteration (context, FALSE);
start = g_get_monotonic_time ();
for (i = 0; i < NSOURCES; i++)
{
sources[i] = g_idle_source_new ();
g_source_set_callback (sources[i], callback, NULL, NULL);
g_source_set_priority (sources[i], i % 100);
g_source_attach (sources[i], context);
}
end = g_get_monotonic_time ();
g_print ("Add different-priority sources: %" G_GINT64_FORMAT "\n",
(end - start) / 1000);
#ifdef SLOW
start = g_get_monotonic_time ();
for (i = 0; i < NSOURCES; i++)
g_assert (sources[i] == g_main_context_find_source_by_id (context, g_source_get_id (sources[i])));
end = g_get_monotonic_time ();
g_print ("Find each source: %" G_GINT64_FORMAT "\n",
(end - start) / 1000);
#endif
shuffle (sources, NSOURCES);
start = g_get_monotonic_time ();
for (i = 0; i < NSOURCES; i++)
{
g_source_destroy (sources[i]);
g_source_unref (sources[i]);
}
end = g_get_monotonic_time ();
g_print ("Remove in random order: %" G_GINT64_FORMAT "\n",
(end - start) / 1000);
/* Make sure they really did get removed */
g_main_context_iteration (context, FALSE);
pool = g_thread_pool_new (thread_pool_attach_func, context,
20, TRUE, NULL);
start = g_get_monotonic_time ();
for (i = 0; i < NSOURCES; i++)
{
sources[i] = g_idle_source_new ();
g_source_set_callback (sources[i], callback, NULL, NULL);
g_thread_pool_push (pool, sources[i], &error);
g_assert_no_error (error);
}
g_thread_pool_free (pool, FALSE, TRUE);
end = g_get_monotonic_time ();
g_print ("Add sources from threads: %" G_GINT64_FORMAT "\n",
(end - start) / 1000);
pool = g_thread_pool_new (thread_pool_destroy_func, context,
20, TRUE, NULL);
start = g_get_monotonic_time ();
for (i = 0; i < NSOURCES; i++)
{
g_thread_pool_push (pool, sources[i], &error);
g_assert_no_error (error);
}
g_thread_pool_free (pool, FALSE, TRUE);
end = g_get_monotonic_time ();
g_print ("Remove sources from threads: %" G_GINT64_FORMAT "\n",
(end - start) / 1000);
/* Make sure they really did get removed */
g_main_context_iteration (context, FALSE);
g_free (sources);
return 0;
}