+/* Check that all threads are working. */
+static void test_parmap_extended(e_xbt_parmap_mode_t mode)
+{
+ unsigned num_workers;
+
+ for (num_workers = 1 ; num_workers <= 16 ; num_workers *= 2) {
+ const unsigned len = 2 * num_workers;
+ uintptr_t *a;
+ xbt_parmap_t parmap;
+ xbt_dynar_t data;
+ unsigned i;
+ unsigned count;
+
+ xbt_test_add("Extended parmap usage (%u workers)", num_workers);
+
+ TEST_PARMAP_VALIDATE_MODE(mode);
+ parmap = xbt_parmap_new(num_workers, mode);
+
+ a = xbt_malloc(len * sizeof *a);
+ data = xbt_dynar_new(sizeof a, NULL);
+ for (i = 0; i < len; i++)
+ xbt_dynar_push_as(data, void *, &a[i]);
+
+ xbt_parmap_apply(parmap, fun_get_id, data);
+
+ qsort(a, len, sizeof a[0], fun_compare);
+ count = 1;
+ for (i = 1; i < len; i++)
+ if (a[i] != a[i - 1])
+ count++;
+ xbt_test_assert(count == num_workers,
+ "only %u/%u threads did some work", count, num_workers);
+
+ xbt_dynar_free(&data);
+ xbt_free(a);
+ xbt_parmap_destroy(parmap);