- Notifications
You must be signed in to change notification settings - Fork0
µFramework consisting of `NSOperationQueue` subclasses (Swift & Obj-C) which allow scheduling operations in serial subgroups inside a concurrent queue
License
p4checo/APNSubGroupOperationQueue
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
Swift & Obj-C µFramework consisting ofNSOperationQueue subclasses which allow scheduling operations in serial subgroups inside concurrent queues.
In some scenarios, operations scheduled in anNSOperationQueue depend on a subset of other operations and should be processed in order, but don't depend on the remaining operations in the queue.
So far, this could be solved by:
- using separate queues for each subset of dependent operations (can become unmanageable, wasteful)
- defining the queue as serial (sub-optimal performance)
With this µFramework, a single operation queue can be used to schedule all operations and obtain the best of both worlds.
Dependent operations are grouped into "subgroups" which are guaranteed to be processed in a serial fashion inside each subgroup, while operations from other subgroups are processed concurrently (while serial inside their own subgroup) and regular operations (i.e. without defined subgroup) are processed concurrently with all others. This is done by leveragingNSOperations dependencies and using an auxiliary data structure to store all subgroups' operations.
@import APNSubGroupOperationQueueletsubGroupQueue=SubGroupOperationQueue<String>()// schedule operations in subgroups "A", "B" and "C"// these will run serially inside each subgroup, but concurrently with other subgroups' operationssubGroupQueue.addOperation(opA1, withKey:"A")subGroupQueue.addOperation(opA2, withKey:"A")subGroupQueue.addOperation(opA3, withKey:"A")subGroupQueue.addOperations([opB1, opB2, opB3], withKey:"B")subGroupQueue.addOperation({ /* opC1 */}, withKey:"C")subGroupQueue.addOperation({ /* opC2 */}, withKey:"C")subGroupQueue.addOperation({ /* opC3 */}, withKey:"C")// query current subgroup's operations (a snapshot)letaOps=subGroupQueue["A"]letbOps=subGroupQueue["B"]letcOps= subGroupQueue.subGroupOperations(forKey:"C")
@import APNSubGroupOperationQueueletdynamicSubGroupQueue= SubGroupQueue<AnyHashable> // or simply a `DynamicSubGroupOperationQueue`dynamicSubGroupQueue.addOperation(opX1, withKey:"X")dynamicSubGroupQueue.addOperation(opX2, withKey:"X")dynamicSubGroupQueue.addOperation(opX3, withKey:"X")dynamicSubGroupQueue.addOperations([opN1, opN2, opN3], withKey:1337)letdate=Date()dynamicSubGroupQueue.addOperation({ /* opD1 */}, withKey: date)dynamicSubGroupQueue.addOperation({ /* opD2 */}, withKey: date)dynamicSubGroupQueue.addOperation({ /* opD3 */}, withKey: date)// query current subgroup's operations (a snapshot)letxOps=subGroupQueue["X"]letnOps=subGroupQueue[1337]letdOps= subGroupQueue.subGroupOperations(forKey: date)
@import APNSubGroupOperationQueue;APNSubGroupOperationQueue *subGroupQueue = [APNSubGroupOperationQueuenew];// schedule operations in subgroups "A", "B" and "C"// these will run serially inside each subgroup, but concurrently with other subgroups' operations[subGroupQueueaddOperation:opA1withKey:@"A"];[subGroupQueueaddOperation:opA2withKey:@"A"];[subGroupQueueaddOperation:opA2withKey:@"A"];[subGroupQueueaddOperations::@[opB1, opB2, opB3]withKey:@"B"waitUntilFinished:false];[subGroupQueueaddOperationWithBlock:^{/* opC1*/ }andKey:@"C"];[subGroupQueueaddOperationWithBlock:^{/* opC2*/ }andKey:@"C"];[subGroupQueueaddOperationWithBlock:^{/* opC3*/ }andKey:@"C"];// query current subgroup's operations (a snapshot)NSArray<NSOperation*> *aOps = [subGroupQueuesubGroupOperationsForKey:@"A"];NSArray<NSOperation*> *bOps = [subGroupQueuesubGroupOperationsForKey:@"B"];NSArray<NSOperation*> *cOps = [subGroupQueuesubGroupOperationsForKey:@"C"];// Objective-C uses a `DynamicSubGroupOperationQueue` which allows a more flexible usage, since keys only need to be `NSObject`'s (`AnyHashable`)[subGroupQueueaddOperations:@[opN1, opN2, opN3]withKey:@1337waitUntilFinished:false];NSDate *date = [NSDatedate];[subGroupQueueaddOperationWithBlock:^{/* opD1*/ }andKey:date];[subGroupQueueaddOperationWithBlock:^{/* opD2*/ }andKey:date];
- iOS 10.0+, macOS 10.12, tvOS 10.0+, watchOS 3.0+
- Xcode 10.2+
- Swift 5.0
- iOS 10.0+, macOS 10.12, tvOS 10.0+, watchOS 3.0+
- Xcode 10
- Swift 4.2
- iOS 8.0+, macOS 10.9+, tvOS 9.0+, watchOS 2.0+
2.3.0- Xcode 9.4
- Swift 4.1
2.2.0- Xcode 9
- Swift 4.0
2.1.0- Xcode 8
- Swift 3
Add APNSubGroupOperationQueue to yourPodfile and runpod install:
# CocoaPodspod'APNSubGroupOperationQueue','~> 4.0'
Add APNSubGroupOperationQueue to yourCartfile (package dependency) orCartfile.private(development dependency):
github "p4checo/APNSubGroupOperationQueue" ~> 4.0Add APNSubGroupOperationQueue to yourPackage.swift:
import PackageDescriptionletpackage=Package( name:"HelloWorld", dependencies:[.package(url:"https://github.com/p4checo/APNSubGroupOperationQueue.git", from:"4.0.0"),])
- Add this repository as a submodule.
- Drag APNSubGroupOperationQueue.xcodeproj into your project or workspace.
- Link your target against APNSubGroupOperationQueue.framework of your platform.
- If linking againts an Application target, ensure the framework gets copied into the bundle. If linking against a Framework target, the application linking to it should also include APNSubGroupOperationQueue.
SeeCONTRIBUTING.
About
µFramework consisting of `NSOperationQueue` subclasses (Swift & Obj-C) which allow scheduling operations in serial subgroups inside a concurrent queue
Topics
Resources
License
Contributing
Uh oh!
There was an error while loading.Please reload this page.