[iOS/Swift] 동시성 프로그래밍 - Dispatch Group

안녕하세요?

너구리입니다.

 

 

오늘은 Dispatch Group에 대해 정리해 보려 합니다

 

 

Dispatch Group 이란?

dispatch group은 무엇을까요?

dispatch를 묶어놓은걸까요?

 

얼추 비슷합니다.

 

공식문서로 개념을 살펴볼게요

- 여러 task를 하나의 유닛으로 관리할 수 있는 그룹입니다.

- item(=task)들을 묶고 동기적인 동기적으로 행동하게 할 수 있다

- 여러 item을 묶고, 비동기적으로 같은 큐나 다른 큐에서 비동기적으로 실행시킨다.

- item들의 작업이 끝나면 컴프리션 핸들러를 실행시킨다. 또한 작업이 끝날때까지 동기적으로 멈출 수 있다.

 

task를 그룹으로 묶어서 관리하는 친구입니다ㅎㅎ

 

그림으로 어떻게 작동하는지 확인해 볼게요!

 

task1,2,3이 group1에 묶여 있습니다!

일단 편의상 여러 스레드에 task에 분배했는데요!

어디 스레드에 있든 마지막 task3가 끝나면

notify를 통해 group1이 끝났다고 알려줍니다!

 

 

이제는 코드로 사용법을 확인해 보겠습니다!ㅎㅎ

let workingQueue = DispatchQueue(label: "neoguri", attributes: .concurrent)
let numberArray = [(0,1), (2,3), (4,5), (6,7), (8,9), (10,11)]

// 디스패치 그룹 생성
let group1 = DispatchGroup()

// 작업들을 비동기적으로 보낼때 "그룹 꼬리표" 붙이기
for inValue in numberArray {
    // 위에서 생성한 디스패치 그룹을 아규먼트에 넣기
    workingQueue.async(group: group1) {
        let result = slowAdd(inValue)
        print("더한 결과값 출력하기 = \(result)")
    }
}

// 그룹의 모든 작업이 완료했을때 알림(notify) 받기
let defaultQueue = DispatchQueue.global()

// 그룹의 notify. 작업이 완료하고 어떤 일을 할 것인지 정하기
group1.notify(queue: defaultQueue) {
    print("====그룹1 안의 모든 작업이 완료====")
}

 

dispatch group을 인스턴스로 만들어 주고

큐에 task를 보낼 때 async 메소드 안 group인자에 생성한 dispatch group인스턴스를 넣어 줍니다!

그리고 group의 모든 item이 동작 완료 되면 실행할 코드를 

group 인스턴스의 notify함수 안에 구현해 줍니다!

그리고 notify에서 수행할 작업도 큐를 지정해 줄 수 있어요!

 

 

그럼  group이 끝날 때 까지 sync를 사용하는 방법은 뭘까?

 

sync를 붙인다? 

놉!!!!

Dispatch group의 wait이라는 함수를 사용해 구현할 수 있어요!

 

이런 작업은 그룹 완료 알림을 비동기적으로 응답할 수 없는 경우 사용합니다.

즉 모든 작업이 완료 될 때까지 큐를 차단하는 동기적 방법이죠

작업이 완료되는 시점까지 기다릴 수도 있고, 완료와 상관없이 일정 시간을 기다릴수도 있어요!

 

다만 주의할점!!!!!

 

저번 포스팅에서 알아보았듯이 메인큐는 멈추면 안되기 때문에

메인 큐에서는 절대 wait을 사용하면 안됩니다!!! 절대!!!

 

그리고 다른 큐에서 사용할때도

큐 자체를 막아버리기 때문에 조심히 사용해야합니다!

 

코드로 어떻게 쓰는지 알아볼게요!

let workingQueue = DispatchQueue(label: "neoguri", attributes: .concurrent)
let numberArray = [(0,1), (2,3), (4,5), (6,7), (8,9), (10,11)]

// 디스패치 그룹 생성
let group1 = DispatchGroup()

// 작업들을 비동기적으로 보낼때 "그룹 꼬리표" 붙이기
for inValue in numberArray {
    // 위에서 생성한 디스패치 그룹을 아규먼트에 넣기
    workingQueue.async(group: group1) {
        let result = slowAdd(inValue)
        print("더한 결과값 출력하기 = \(result)")
    }
}

if group1.wait(timeout: .now() + 60) == .timedOut {
    print("모든 작업이 60초 안에 끝나진 않았습니다.")
}

이렇게 사용할 수 있습니다.

 

해당 코드는 실행이 안될겁니다.

왜냐하면 group1이 60초를 넘기지 않을것이니까요.

다만 사용법을 보여드리기 위해 작성하였습니다!

 

 

글 읽어주셔서 감사합니다.

 

출처 : https://www.inflearn.com/course/iOS-Concurrency-GCD-Operation/dashboard

iOS Concurrency(동시성) 프로그래밍, 동기 비동기 처리 그리고 GCD/Operation - 디스패치큐와 오퍼레이션