NCOperationQueue.swift 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  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: NSObject {
  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. @objc func download(metadata: tableMetadata, selector: String, setFavorite: Bool) {
  32. transferQueue.addOperation(NCOperation.init(metadata: metadata, selector: selector, setFavorite: setFavorite))
  33. }
  34. // @objc func downloadThumbnail(with metadata: tableMetadata, view: Any, indexPath: IndexPath) {
  35. // operationQueueNetworkingMain.addOperation(NCOperationNetworkingMain.init(metadata: metadata, view: view, indexPath: indexPath, networkingFunc: "downloadThumbnail"))
  36. // }
  37. }
  38. @objc class NCOperation: ConcurrentOperation {
  39. private var metadata: tableMetadata
  40. private var selector: String
  41. private var setFavorite: Bool
  42. init(metadata: tableMetadata, selector: String, setFavorite: Bool) {
  43. self.metadata = metadata
  44. self.selector = selector
  45. self.setFavorite = setFavorite
  46. }
  47. override func start() {
  48. NCNetworking.shared.download(metadata: self.metadata, selector: self.selector, setFavorite: self.setFavorite) { (_) in
  49. self.finish()
  50. }
  51. }
  52. /*
  53. override func finish(success: Bool = true) {
  54. self.finish()
  55. }
  56. */
  57. /*
  58. @objc func download(metadata: tableMetadata, selector: String, setFavorite: Bool = false) {
  59. let concurrentOperation = ConcurrentOperation { operation in
  60. NCNetworking.shared.download(metadata: metadata, selector: selector, setFavorite: setFavorite) { (errorCode) in
  61. self.semaphore.wait()
  62. }
  63. }
  64. concurrentOperation.addToQueue(transferQueue)
  65. debugPrint("[LOG] Download ADD QUEUE")
  66. semaphore.wait()
  67. }
  68. */
  69. }