starred/CoreStore
1
0
Fork 0
mirror of https://github.com/JohnEstropia/CoreStore.git synced 2026-03-23 09:51:30 +01:00
Code Issues 95 Packages Projects Releases 10 Wiki Activity

avoid using default queue qos

Browse Source
This commit is contained in:
John Estropia
2020-12-26 23:45:11 +09:00
parent 5de5ecee06
commit e1aed37da0
6 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Sources/BaseDataTransaction.swift
View File

@@ -429,7 +429,7 @@ public /*abstract*/ class BaseDataTransaction {
internal let context: NSManagedObjectContext internal let context: NSManagedObjectContext
internal let transactionQueue: DispatchQueue internal let transactionQueue: DispatchQueue
internal let childTransactionQueue = DispatchQueue.serial("com.corestore.datastack.childTransactionQueue") internal let childTransactionQueue = DispatchQueue.serial("com.corestore.datastack.childTransactionQueue", qos: .utility)
internal let supportsUndo: Bool internal let supportsUndo: Bool
internal let bypassesQueueing: Bool internal let bypassesQueueing: Bool
internal var isCommitted = false internal var isCommitted = false

2
Sources/CoreStoreDefaults.swift
View File

@@ -69,7 +69,7 @@ public enum CoreStoreDefaults {
// MARK: Private // MARK: Private
private static let defaultStackBarrierQueue = DispatchQueue.concurrent("com.coreStore.defaultStackBarrierQueue") private static let defaultStackBarrierQueue = DispatchQueue.concurrent("com.coreStore.defaultStackBarrierQueue", qos: .userInteractive)
private static var defaultStackInstance: DataStack? private static var defaultStackInstance: DataStack?
} }

2
Sources/CoreStoreManagedObject.swift
View File

@@ -48,6 +48,6 @@ import Foundation
private enum Static { private enum Static {
static let queue = DispatchQueue.concurrent("com.coreStore.coreStoreManagerObjectBarrierQueue") static let queue = DispatchQueue.concurrent("com.coreStore.coreStoreManagerObjectBarrierQueue", qos: .userInteractive)
static var cache: [ObjectIdentifier: [KeyPathString: Set<KeyPathString>]] = [:] static var cache: [ObjectIdentifier: [KeyPathString: Set<KeyPathString>]] = [:]
} }

2
Sources/CoreStoreSchema.swift
View File

@@ -254,7 +254,7 @@ public final class CoreStoreSchema: DynamicSchema {
// MARK: Private // MARK: Private
private static let barrierQueue = DispatchQueue.concurrent("com.coreStore.coreStoreDataModelBarrierQueue") private static let barrierQueue = DispatchQueue.concurrent("com.coreStore.coreStoreDataModelBarrierQueue", qos: .userInteractive)
private let allEntities: Set<DynamicEntity> private let allEntities: Set<DynamicEntity>

4
Sources/DataStack.swift
View File

@@ -440,8 +440,8 @@ public final class DataStack: Equatable {
internal let rootSavingContext: NSManagedObjectContext internal let rootSavingContext: NSManagedObjectContext
internal let mainContext: NSManagedObjectContext internal let mainContext: NSManagedObjectContext
internal let schemaHistory: SchemaHistory internal let schemaHistory: SchemaHistory
internal let childTransactionQueue = DispatchQueue.serial("com.coreStore.dataStack.childTransactionQueue") internal let childTransactionQueue = DispatchQueue.serial("com.coreStore.dataStack.childTransactionQueue", qos: .utility)
internal let storeMetadataUpdateQueue = DispatchQueue.concurrent("com.coreStore.persistentStoreBarrierQueue") internal let storeMetadataUpdateQueue = DispatchQueue.concurrent("com.coreStore.persistentStoreBarrierQueue", qos: .userInteractive)
internal let migrationQueue: OperationQueue = Internals.with { internal let migrationQueue: OperationQueue = Internals.with {
let migrationQueue = OperationQueue() let migrationQueue = OperationQueue()

4
Sources/DispatchQueue+CoreStore.swift
View File

@@ -31,7 +31,7 @@ import Foundation
extension DispatchQueue { extension DispatchQueue {
@nonobjc @inline(__always) @nonobjc @inline(__always)
internal static func serial(_ label: String, qos: DispatchQoS = .default) -> DispatchQueue { internal static func serial(_ label: String, qos: DispatchQoS) -> DispatchQueue {
return DispatchQueue( return DispatchQueue(
label: label, label: label,
@@ -43,7 +43,7 @@ extension DispatchQueue {
} }
@nonobjc @inline(__always) @nonobjc @inline(__always)
internal static func concurrent(_ label: String, qos: DispatchQoS = .default) -> DispatchQueue { internal static func concurrent(_ label: String, qos: DispatchQoS) -> DispatchQueue {
return DispatchQueue( return DispatchQueue(
label: label, label: label,