libdispatch-84.5.3.tar.gz

[apple/libdispatch.git] / testing / dispatch_overcommit.c

diff --git a/testing/dispatch_overcommit.c b/testing/dispatch_overcommit.c
new file mode 100644 (file)
index 0000000..af5e59a
--- /dev/null
+++ b/testing/dispatch_overcommit.c
@@ -0,0 +1,45 @@
+#include <dispatch/dispatch.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <assert.h>
+#include <libkern/OSAtomic.h>
+
+#include "dispatch_test.h"
+
+int32_t count = 0;
+const int32_t final = 32;
+
+int
+main(void)
+{
+       test_start("Dispatch Overcommit");
+
+       dispatch_queue_attr_t attr = dispatch_queue_attr_create();
+       test_ptr_notnull("dispatch_queue_attr_create", attr);
+       dispatch_queue_attr_set_flags(attr, DISPATCH_QUEUE_OVERCOMMIT);
+       
+       int i;
+       for (i = 0; i < final; ++i) {
+               char* name;
+               asprintf(&name, "test.overcommit.%d", i);
+               
+               dispatch_queue_t queue = dispatch_queue_create(name, attr);
+               test_ptr_notnull("dispatch_queue_create", queue);
+               free(name);
+               
+               dispatch_async(queue, ^{
+                       OSAtomicIncrement32(&count);
+                       if (count == final) {
+                               test_long("count", count, final);
+                               test_stop();
+                       } else {
+                               while (1); // spin
+                       }
+               });
+       }
+       
+       dispatch_main();
+
+       return 0;
+}