Observe whether All Operation is completed or not using swift 4.2

All Operation is completed or not

In iOS basically we perform the background thread operation using GCD & OPeration, OPerationQueue.

In GCD there is DispatchGroup for handling the work is completed or not (different DispatchWorkItem ). In Operation, there is no kind of facility for this we have to create KVO

to manage all things. here we have taken the example of 2 Operation each Operation is downloading the image.

Please follow these steps:

1: First Create Operation class that will download the image.

class AsyncTask:Operation{
    
    var imageURL:URL
    
    
    init(url:URL) {
        self.imageURL = url
    }
    
    
    override func main() {
        //4
        if isCancelled {
            return
        }
        
        //5
        guard let imageData = try? Data(contentsOf: imageURL) else { return }
        
        //6
        if isCancelled {
            return
        }
        
        if !imageData.isEmpty{
            print("downloaded")
        }
    }
    
}

class AsyncTask:Operation{

var imageURL:URL

init(url:URL) {

self.imageURL = url

}

override func main() {

//4

if isCancelled {

return

}

//5

guard let imageData = try? Data(contentsOf: imageURL) else { return }

//6

if isCancelled {

return

}

if !imageData.isEmpty{

print("downloaded")

}

2: Take a controller class and Declare OperationQueue.

class ViewController: UIViewController {

let queue = OperationQueue()
var observation : NSKeyValueObservation?



}

class ViewController: UIViewController {

let queue = OperationQueue()

var observation : NSKeyValueObservation?

}

Notes: It will add all the operations in the queue.

3: Write the function for operation.

func callAPI_OPERATION(){

        if let urlDAta1 = URL(string: "https://picsum.photos/id/579/200/300"){
            let op1 = AsyncTask(url:urlDAta1)
            op1.queuePriority = .high
                
            queue.addOperation(op1)
            
            op1.completionBlock = {
                print("op1")
            }
            
            
        }
        
        if let urlDAta2 = URL(string: "https://picsum.photos/id/579/200/300"){
            let op1 = AsyncTask(url:urlDAta2)
            
            queue.addOperation(op1)
            
            op1.completionBlock = {
                print("op2")
            }
        }
    }

func callAPI_OPERATION(){

if let urlDAta1 = URL(string: "https://picsum.photos/id/579/200/300"){

let op1 = AsyncTask(url:urlDAta1)

op1.queuePriority = .high

queue.addOperation(op1)

op1.completionBlock = {

print("op1")

}

if let urlDAta2 = URL(string: "https://picsum.photos/id/579/200/300"){

let op1 = AsyncTask(url:urlDAta2)

queue.addOperation(op1)

op1.completionBlock = {

print("op2")

}

Note: here op1 & op2 is separate completion of the operation.

4: Now Observe all the operation is completed or not.

Write this code in your class.

observation = queue.observe(\.operationCount, options: [.new]) { [unowned self] (queue, change) in
            if change.newValue! == 0 {
                  // This will call when All Opeartion complete.
                self.observation = nil
                
            }
        }

observation = queue.observe(\.operationCount, options: [.new]) { [unowned self] (queue, change) in

if change.newValue! == 0 {

// This will call when All Opeartion complete.

self.observation = nil

}

Now: Here we have implemented KVO to check whether the Queue contains operation or not.

Complete Code :

class ViewController: UIViewController {
    
    let queue = OperationQueue()
    var observation : NSKeyValueObservation?
    
    
    override func viewDidLoad() {
        super.viewDidLoad()
        queue.qualityOfService = .userInitiated
        
        observation = queue.observe(\.operationCount, options: [.new]) { [unowned self] (queue, change) in
            if change.newValue! == 0 {
                self.observation = nil
            }

        }
        
        self.callAPI_OPERATION()
    }
    
    func callAPI_OPERATION(){
        if let urlDAta1 = URL(string: "https://picsum.photos/id/579/200/300"){
            let op1 = AsyncTask(url:urlDAta1)
            op1.queuePriority = .high
            queue.addOperation(op1)
            
            op1.completionBlock = {
                print("op1")
            }
            
            
        }
        
        if let urlDAta2 = URL(string: "https://picsum.photos/id/579/200/300"){
            let op1 = AsyncTask(url:urlDAta2)
            queue.addOperation(op1)
            
            op1.completionBlock = {
                print("op2")
            }
        }
        
    }
    
}



class AsyncTask:Operation{
    
    var imageURL:URL
    
    
    init(url:URL) {
        self.imageURL = url
    }
    
    
    override func main() {
        //4
        if isCancelled {
            return
        }
        
        //5
        guard let imageData = try? Data(contentsOf: imageURL) else { return }
        
        //6
        if isCancelled {
            return
        }
        
        if !imageData.isEmpty{
            print("downloaded")
        }
    }
    
    
}

class ViewController: UIViewController {

let queue = OperationQueue()

var observation : NSKeyValueObservation?

override func viewDidLoad() {

super.viewDidLoad()

queue.qualityOfService = .userInitiated

observation = queue.observe(\.operationCount, options: [.new]) { [unowned self] (queue, change) in

if change.newValue! == 0 {

self.observation = nil

}

self.callAPI_OPERATION()

}

func callAPI_OPERATION(){

if let urlDAta1 = URL(string: "https://picsum.photos/id/579/200/300"){

let op1 = AsyncTask(url:urlDAta1)

op1.queuePriority = .high

queue.addOperation(op1)

op1.completionBlock = {

print("op1")

}

if let urlDAta2 = URL(string: "https://picsum.photos/id/579/200/300"){

let op1 = AsyncTask(url:urlDAta2)

queue.addOperation(op1)

op1.completionBlock = {

print("op2")

}

class AsyncTask:Operation{

var imageURL:URL

init(url:URL) {

self.imageURL = url

}

override func main() {

//4

if isCancelled {

return

}

//5

guard let imageData = try? Data(contentsOf: imageURL) else { return }

//6

if isCancelled {

return

}

if !imageData.isEmpty{

print("downloaded")

}

Reference:

Recent Xcode, iOS and Swift Blog posts

kunal prasad 24 December 2019

. . .

Observe whether All Operation is completed or not using swift 4.2

All Operation is completed or not

1: First Create Operation class that will download the image.

2: Take a controller class and Declare OperationQueue.

3: Write the function for operation.

4: Now Observe all the operation is completed or not.

Leave a Comment Cancel Reply

Message Sent!