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

iOS: remove mutable copy (may caused alloc exception when oom)

Browse Source 
use barrier async dispatch queue to avoid multi-threading error
This commit is contained in:
王劲鹏 2021-07-09 15:58:25 +08:00 committed by osborn
parent 5224df5369
commit fc28d3b90d
1 changed files with 27 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
doric-iOS/Pod/Classes/Plugin/DoricNotificationPlugin.m
View File

@ -22,18 +22,27 @@
@interface DoricNotificationPlugin ()
@property(nonatomic, strong) NSDictionary<NSString *, id> *observers;
@property(nonatomic, strong) NSMutableDictionary<NSString *, id> *observers;
@property (nonatomic, strong) dispatch_queue_t syncQuene;
@end
@implementation DoricNotificationPlugin
- (NSDictionary *)observers {
if (!_observers) {
_observers = [NSDictionary new];
_observers = [NSMutableDictionary new];
}
return _observers;
}
- (dispatch_queue_t)syncQuene {
if (!_syncQuene) {
_syncQuene = dispatch_queue_create("pub.doric.plugin.notification", DISPATCH_QUEUE_CONCURRENT);
}
return _syncQuene;
}
- (void)publish:(NSDictionary *)dic withPromise:(DoricPromise *)promise {
NSString *biz = [dic optString:@"biz"];
NSString *name = [dic optString:@"name"];
@ -70,26 +79,33 @@ - (void)subscribe:(NSDictionary *)dic withPromise:(DoricPromise *)promise {
DoricPromise *currentPromise = [[DoricPromise alloc] initWithContext:self.doricContext callbackId:callbackId];
[currentPromise resolve:note.userInfo];
}];
NSMutableDictionary *mutableDictionary = [self.observers mutableCopy];
mutableDictionary[callbackId] = observer;
self.observers = mutableDictionary;
dispatch_barrier_async(self.syncQuene, ^{
[self.observers setObject:observer forKey:callbackId];
});
[promise resolve:callbackId];
}
- (void)unsubscribe:(NSString *)subscribeId withPromise:(DoricPromise *)promise {
id observer = self.observers[subscribeId];
__block id observer = nil;
dispatch_sync(self.syncQuene, ^{
observer = [self.observers objectForKey:subscribeId];
});
if (observer) {
[[NSNotificationCenter defaultCenter] removeObserver:observer];
NSMutableDictionary *mutableDictionary = [self.observers mutableCopy];
[mutableDictionary removeObjectForKey:subscribeId];
self.observers = mutableDictionary;
dispatch_barrier_async(self.syncQuene, ^{
[self.observers removeObjectForKey:subscribeId];
});
}
[promise resolve:nil];
}
- (void)dealloc {
NSDictionary *dictionary = self.observers;
[dictionary enumerateKeysAndObjectsUsingBlock:^(NSString *key, id obj, BOOL *stop) {
__block NSArray *values;
dispatch_sync(self.syncQuene, ^{
values = [self.observers allValues];
});
[values enumerateObjectsUsingBlock:^(id obj, NSUInteger index, BOOL *stop) {
[[NSNotificationCenter defaultCenter] removeObserver:obj];
}];
}