-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathMDDAccessor.m
More file actions
82 lines (63 loc) · 2.22 KB
/
MDDAccessor.m
File metadata and controls
82 lines (63 loc) · 2.22 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
//
// MDDAccessor.m
// MDDatabase
//
// Created by xulinfeng on 2017/8/8.
// Copyright © 2017年 modool. All rights reserved.
//
#import "MDDAccessor.h"
#import "MDDProcessor+Private.h"
#import "MDDProcessor+MDDatabase.h"
#import "MDDatabase.h"
@interface MDDAccessor ()
@property (nonatomic, assign, readonly) void *queueTag;
@end
@implementation MDDAccessor
- (instancetype)initWithClass:(Class<MDDObject>)class database:(MDDatabase *)database;{
return [self initWithClass:class database:database queue:nil];
}
- (instancetype)initWithClass:(Class<MDDObject>)class database:(MDDatabase *)database queue:(dispatch_queue_t)queue;{
if (self = [super init]) {
_objectClass = class;
_database = database;
NSString *queueName = [NSString stringWithFormat:@"com.modool.database.queue.default%llu", (unsigned long long)self];
queue = queue ?: dispatch_queue_create(queueName.UTF8String, NULL);
_queue = queue;
_queueTag = &_queueTag;
dispatch_queue_set_specific(queue, _queueTag, _queueTag, NULL);
NSError *error = nil;
_tableInfo = [database requireInfoWithClass:class error:&error];
NSAssert(_tableInfo && !error, [error description]);
}
return self;
}
- (NSString *)description{
return [[self dictionaryWithValuesForKeys:@[@"objectClass", @"database", @"tableInfo", @"queue"]] description];
}
- (void)_sync:(dispatch_block_t)block;{
if (dispatch_get_specific(_queueTag)) {
block();
} else {
dispatch_sync(_queue, block);
}
}
- (void)_async:(dispatch_block_t)block;{
if (dispatch_get_specific(_queueTag)) {
block();
} else {
dispatch_async(_queue, block);
}
}
- (void)sync:(void (^)(id<MDDProcessor, MDDCoreProcessor> processor))block;{
MDDProcessor *operator = [[MDDProcessor alloc] initWithClass:_objectClass database:_database tableInfo:_tableInfo];
[self _sync:^{
block(operator);
}];
}
- (void)async:(void (^)(id<MDDProcessor, MDDCoreProcessor> processor))block;{
MDDProcessor *operator = [[MDDProcessor alloc] initWithClass:_objectClass database:_database tableInfo:_tableInfo];
[self _async:^{
block(operator);
}];
}
@end