Skip to content

Commit 7b824ee

Browse files
committed
调整消息处理队列的优先级
1 parent 0f79ab5 commit 7b824ee

1 file changed

Lines changed: 6 additions & 9 deletions

File tree

Bark/AppDelegate+Realm.swift

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88

99
import UIKit
1010

11-
private let pendingMessageProcessingQueue = DispatchQueue(label: "me.fin.bark.pending-message-processing", qos: .utility)
11+
private let pendingMessageProcessingQueue = DispatchQueue(label: "me.fin.bark.pending-message-processing", qos: .userInitiated)
1212
let kBarkMessagesDidChangeNotification = Notification.Name("com.bark.messagesDidChange")
1313

1414
extension AppDelegate {
@@ -96,6 +96,10 @@ extension AppDelegate {
9696
return
9797
}
9898

99+
guard let realm = try? Realm() else {
100+
return
101+
}
102+
99103
let pendingMessagesDir = groupUrl.appendingPathComponent("pending_messages")
100104
let plistFiles: [URL]
101105
if FileManager.default.fileExists(atPath: pendingMessagesDir.path),
@@ -110,23 +114,16 @@ extension AppDelegate {
110114
plistFiles = []
111115
}
112116

113-
guard let realm = try? Realm() else {
114-
return
115-
}
116-
117117
var messagesToAdd: [Message] = []
118-
var urlsToDelete: [URL] = []
119118
let now = Date()
120119
var didChangeMessages = false
121120

122121
for plistUrl in plistFiles {
123122
guard let dict = NSDictionary(contentsOf: plistUrl) as? [String: Any] else {
124-
urlsToDelete.append(plistUrl)
125123
continue
126124
}
127125

128126
let message = Message(dict: dict)
129-
urlsToDelete.append(plistUrl)
130127
if let expireDate = message.expireDate, expireDate <= now {
131128
continue
132129
}
@@ -155,7 +152,7 @@ extension AppDelegate {
155152
}
156153
}
157154

158-
for plistUrl in urlsToDelete {
155+
for plistUrl in plistFiles {
159156
try? FileManager.default.removeItem(at: plistUrl)
160157
}
161158

0 commit comments

Comments
 (0)