12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152 |
- import Foundation
- import Queuer
- @objc class NCOperationQueue: ConcurrentOperation {
- @objc public static let shared: NCOperationQueue = {
- let instance = NCOperationQueue()
- return instance
- }()
-
- let transferQueue = Queuer(name: "transferQueue", maxConcurrentOperationCount: 5, qualityOfService: .default)
- let semaphore = Semaphore()
- @objc func download(metadata: tableMetadata, selector: String, setFavorite: Bool = false) {
- let concurrentOperation = ConcurrentOperation { operation in
-
- NCNetworking.shared.download(metadata: metadata, selector: selector, setFavorite: setFavorite) { (errorCode) in
-
- self.semaphore.continue()
- }
- }
- concurrentOperation.addToQueue(transferQueue)
-
- debugPrint("[LOG] Download ADD QUEUE")
- semaphore.wait()
- }
- }
|