tianzixuan/Doric
Archived
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

iOS: add thread-safe handling for JSDispatcher

Browse Source
This commit is contained in:
pengfei.zhou 2023-05-09 11:52:13 +08:00 committed by jingpeng
parent 542f73e0fd
commit d92ce26248
1 changed files with 41 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

67
doric-iOS/Pod/Classes/Util/DoricJSDispatcher.m
View File

@ -22,42 +22,57 @@
@interface DoricJSDispatcher ()
@property(nonatomic, strong) NSMutableArray <DoricAsyncResult *(^)(void)> *blocks;
@property(nonatomic, assign) BOOL consuming;
@property(nonatomic, strong) dispatch_queue_t syncQueue;
@end
@implementation DoricJSDispatcher
- (instancetype)init {
if (self = [super init]) {
_syncQueue = dispatch_queue_create("DoricJSDispatcher", DISPATCH_QUEUE_CONCURRENT);
}
return self;
}
- (void)dispatch:(DoricAsyncResult *(^)(void))block {
if (!self.blocks) {
self.blocks = [@[block] mutableCopy];
} else {
if (self.blocks.count > 0) {
[self.blocks removeAllObjects];
dispatch_barrier_async(self.syncQueue, ^{
if (!self.blocks) {
self.blocks = [@[block] mutableCopy];
} else {
if (self.blocks.count > 0) {
[self.blocks removeAllObjects];
}
[self.blocks insertObject:block atIndex:0];
}
[self.blocks insertObject:block atIndex:0];
}
if (!self.consuming) {
[self consume];
}
if (!self.consuming) {
[self consume];
}
});
}
- (void)consume {
DoricAsyncResult *(^block )(void) = self.blocks.lastObject;
if (block) {
self.consuming = YES;
[self.blocks removeLastObject];
DoricAsyncResult *result = block();
__weak typeof(self) __self = self;
result.finishCallback = ^{
dispatch_async(dispatch_get_main_queue(), ^{
__strong typeof(__self) self = __self;
[self consume];
});
};
} else {
self.consuming = NO;
}
dispatch_barrier_async(self.syncQueue, ^{
DoricAsyncResult *(^block )(void) = self.blocks.lastObject;
if (block) {
self.consuming = YES;
[self.blocks removeLastObject];
DoricAsyncResult *result = block();
__weak typeof(self) __self = self;
result.finishCallback = ^{
dispatch_async(dispatch_get_main_queue(), ^{
__strong typeof(__self) self = __self;
[self consume];
});
};
} else {
self.consuming = NO;
}
});
}
- (void)clear {
[self.blocks removeAllObjects];
dispatch_barrier_async(self.syncQueue, ^{
[self.blocks removeAllObjects];
});
}
@end