Added AEMainThreadEndpoint stress test

cjhanson · Jul 2, 2016 · 310aeb6 · 310aeb6
1 parent 45e8614
commit 310aeb6
Showing 1 changed file with 18 additions and 0 deletions.
diff --git a/Tests/AECrossThreadMessagingTests.m b/Tests/AECrossThreadMessagingTests.m
@@ -62,6 +62,24 @@ - (void)testMainThreadEndpointMessaging {
     XCTAssertNil(weakEndpoint);
 }
 
+- (void)testMainThreadEndpointStressTest {
+    __block int counter = 0;
+    AEMainThreadEndpoint * endpoint = [[AEMainThreadEndpoint alloc] initWithHandler:^(const void *data, size_t length) {
+        counter++;
+    }];
+
+    dispatch_async(dispatch_get_global_queue(QOS_CLASS_DEFAULT, 0), ^{
+        for ( int i=0; i<100; i++) {
+            AEMainThreadEndpointSend(endpoint, NULL, 0);
+            usleep(100);
+        }
+    });
+
+    [[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow:0.2]];
+
+    XCTAssertEqual(counter, 100);
+}
+
 - (void)testAudioThreadEndpointMessaging {
     NSMutableArray * messages = [NSMutableArray array];
     AEAudioThreadEndpoint * endpoint = [[AEAudioThreadEndpoint alloc] initWithHandler:^(const void *data, size_t length) {