1 /* test for gslice cross thread allocation/free
2 * Copyright (C) 2006 Stefan Westerfeld
3 * Copyright (C) 2007 Tim Janik
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2 of the License, or (at your option) any later version.
10 * This library is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Lesser General Public License for more details.
15 * You should have received a copy of the GNU Lesser General Public
16 * License along with this library; if not, write to the
17 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
18 * Boston, MA 02111-1307, USA.
25 #define N_ALLOCS 50000
26 #define MAX_BLOCK_SIZE 64
34 void* to_free
[N_THREADS
* N_ALLOCS
];
35 int bytes_to_free
[N_THREADS
* N_ALLOCS
];
41 thread_func (void *arg
)
43 struct ThreadData
*td
= arg
;
45 /* g_print ("Thread %d starting\n", td->thread_id); */
46 for (i
= 0; i
< N_ALLOCS
; i
++)
48 if (rand() % (N_ALLOCS
/ 20) == 0)
49 g_print ("%c", 'a' - 1 + td
->thread_id
);
51 /* allocate block of random size and randomly fill */
52 int bytes
= rand() % MAX_BLOCK_SIZE
+ 1;
53 char *mem
= g_slice_alloc (bytes
);
55 for (f
= 0; f
< bytes
; f
++)
58 /* associate block with random thread */
59 int t
= rand() % N_THREADS
;
60 g_mutex_lock (&tdata
[t
].to_free_mutex
);
61 tdata
[t
].to_free
[tdata
[t
].n_to_free
] = mem
;
62 tdata
[t
].bytes_to_free
[tdata
[t
].n_to_free
] = bytes
;
64 g_mutex_unlock (&tdata
[t
].to_free_mutex
);
66 /* shuffle thread execution order every once in a while */
70 g_thread_yield(); /* concurrent shuffling for single core */
72 g_usleep (1000); /* concurrent shuffling for multi core */
75 /* free a block associated with this thread */
76 g_mutex_lock (&td
->to_free_mutex
);
77 if (td
->n_to_free
> 0)
80 g_slice_free1 (td
->bytes_to_free
[td
->n_to_free
], td
->to_free
[td
->n_to_free
]);
83 g_mutex_unlock (&td
->to_free_mutex
);
94 for (t
= 0; t
< N_THREADS
; t
++)
96 tdata
[t
].thread_id
= t
+ 1;
97 tdata
[t
].n_to_free
= 0;
100 g_print ("Starting %d threads for concurrent GSlice usage...\n", N_THREADS
);
101 for (t
= 0; t
< N_THREADS
; t
++)
103 tdata
[t
].gthread
= g_thread_create (thread_func
, &tdata
[t
], TRUE
, NULL
);
104 g_assert (tdata
[t
].gthread
!= NULL
);
106 for (t
= 0; t
< N_THREADS
; t
++)
108 g_thread_join (tdata
[t
].gthread
);
111 for (t
= 0; t
< N_THREADS
; t
++)
113 g_print ("Thread %d: %d blocks freed, %d blocks not freed\n",
114 tdata
[t
].thread_id
, tdata
[t
].n_freed
, tdata
[t
].n_to_free
);