NCOperationQueue.swift 1.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. //
  2. // NCOperationQueue.swift
  3. // Nextcloud
  4. //
  5. // Created by Marino Faggiana on 03/06/2020.
  6. // Copyright © 2020 Marino Faggiana. All rights reserved.
  7. //
  8. // Author Marino Faggiana <marino.faggiana@nextcloud.com>
  9. //
  10. // This program is free software: you can redistribute it and/or modify
  11. // it under the terms of the GNU General Public License as published by
  12. // the Free Software Foundation, either version 3 of the License, or
  13. // (at your option) any later version.
  14. //
  15. // This program is distributed in the hope that it will be useful,
  16. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  17. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  18. // GNU General Public License for more details.
  19. //
  20. // You should have received a copy of the GNU General Public License
  21. // along with this program. If not, see <http://www.gnu.org/licenses/>.
  22. //
  23. import Foundation
  24. import Queuer
  25. @objc class NCOperationQueue: ConcurrentOperation {
  26. @objc public static let shared: NCOperationQueue = {
  27. let instance = NCOperationQueue()
  28. return instance
  29. }()
  30. let transferQueue = Queuer(name: "transferQueue", maxConcurrentOperationCount: 5, qualityOfService: .default)
  31. let semaphore = Semaphore()
  32. @objc func download(metadata: tableMetadata, selector: String, setFavorite: Bool = false) {
  33. let concurrentOperation = ConcurrentOperation { operation in
  34. NCNetworking.shared.download(metadata: metadata, selector: selector, setFavorite: setFavorite) { (errorCode) in
  35. self.semaphore.continue()
  36. }
  37. }
  38. concurrentOperation.addToQueue(transferQueue)
  39. debugPrint("[LOG] Download ADD QUEUE")
  40. semaphore.wait()
  41. }
  42. }