[iOS] 동시성 프로그래밍(6) - Concurrency Problems
2023. 1. 10. 22:29
iOS/iOS
concurrency problem(동시성 문제)란멀티 쓰레딩 환경에서 공유자원에 동시에 접근하여 발생하는 문제를 말한다. 동시성 문제에는 크게 3가지가 있다. Race Condition (경쟁 상태)DeadLock (교착 상태)Priority Inversion (우선순위 뒤바뀜) Race Condition Race Condition(경쟁상태)이란,공유자원에 여러 쓰레드가 동시에 접근하게 되어, 작업의 접근 순서에 따라 결과가 바뀌는 문제를 의미한다. 더 정확히 얘기하자면, 공유자원에 대한 쓰기 작업에 의해 발생한다. (읽기 작업은 상관없음)for i in 1...5 { print("--- \(i)번째 ---") let group = DispatchGroup() var s..
[RxSwift] Operator(3) - Combining
2023. 1. 8. 19:12
iOS/RxSwift
이번 포스팅에서는 sequence들을 모으고, 여러 sequence내의 데이터들을 병합하는 방법에 대해 알아보자. startWith(_:) subscriber가 Observable을 구독하고, 요소를 방출받을 때 초기값을 지정해 주는 연산자이다. Observable의 타입과 초기값의 타입이 같아야 한다. let observable = Observable.of("A", "B", "C") observable .startWith("alphabet will start to emit") .subscribe( onNext: { print($0) } ) .disposed(by: disposBag) /* prints: alphabet will start to emit A B C */ concat(_:) concat은 ..
[iOS] 동시성 프로그래밍(5) - DispatchSemaphore
2023. 1. 4. 21:35
iOS/iOS
Semaphore동시성 프로그래밍에서는 여러 작업들이 공유 자원을 사용하기 때문에, 여러가지 문제가 발생한다. 이러한 문제들은 둘 이상의 작업들이 공유자원에 접근하면 문제가 생기는 코드 영역인 Critical Section에서 발생하는데, 공유자원에 접근하여 발생하는 문제 중 하나로 두 작업의 접근 순서에 따라 결과가 바뀌는 문제가 있다.for _ in 1...5 { let group = DispatchGroup() var someNumber = 10 DispatchQueue.global().async(group: group) { someNumber *= 10 } DispatchQueue.global().async(group: group) { ..
[iOS] 동시성 프로그래밍(4) - DispatchWorkItem
2023. 1. 4. 17:28
iOS/iOS
기존의 DispatchQueue에서의 작업은 다음과 같이 클로저 형태로 작성하였다. DispatchQueue.global().sync { task(1) task(2) } DispatchQueue.global().async { task(1) task(2) } 하지만, 같은 작업이 반복되는 경우 똑같은 코드를 작성해야 하는데, DipsatchWorkItem을 사용하면 작업들을 캡슐화하여 재사용성을 늘릴 수 있다. DispatchWorkItem DispatchWorkItem은 작업들을 캡슐화 할 수 있는데, 사용은 다음과 같다. let workItem = DispatchWorkItem { task(1) task(2) } DispatchQueue.global().async(execute: workItem) Di..
[iOS] 동시성 프로그래밍(2) - GCD(Grand Central Dispatch)
2023. 1. 2. 23:34
iOS/iOS
지난 포스팅에서 "iOS는 GCD, NSOperation를 통해 멀티쓰레딩을 통한 동시성 프로그래밍을 지원한다" 언급하였는데, 이 중 GCD에 대해 이번 포스팅에서 알아보자. 우선 GCD는 애플에서 제공하는 "멀티 쓰레딩" 처리를 쉽고 편하게 해주는 API이다. 또한 "큐에 넣기만 하면 알아서 쓰레드로 분배해 준다"라고 하였는데, GCD에서의 해당 큐가 Dispatch Queue이다. Dispatch Queue DispatchQueue는 아래와 같이 사용이 가능한데, "큐의 종류", "qos 옵션", "동기/비동기" 에 대한 설정이 가능한데, 이들에 대해 순차적으로 알아보자! Queue의 종류 Dispatch Queue의 종류에는 3가지가 있다. main Queue global Queue custom Q..
[iOS] 동시성 프로그래밍(1)
2022. 12. 30. 18:19
iOS/iOS
동시성 프로그래밍이란 "작업들을 동시에 처리하는 프로그래밍"을 의미한다. 이는 병렬 프로그래밍과 다른 개념인데, 동시성 프로그래밍은 하나의 processor가 A 작업과 B 작업을 왔다갔다 하며 동시에 처리하는 반면, 병렬 프로그래밍은 두개 이상의 processor가 A와 B를 하나씩 맡아 동시에 처리하는 것이다. processor에서 multi-core를 활용하기 위해, software에선 "수행해야 할 작업(Task)들을 동시에 처리"하는 동시성 프로그래밍이 필요하다. 동시성 프로그래밍은 크게 3가지를 통해 이루어질 수 있는데, 이번 포스팅에서는 이중 "멀티 쓰레딩"을 알아볼 것이다. 이에 앞서, Thread 개념에 대해 간단하게 알아보자. Thread Thread에 대해 이해하기 앞서 간단하게 Pr..
[RxSwift] Traits
2022. 12. 28. 16:47
iOS/RxSwift
Traits란 기존의 Observable의 wrapper 구조체로, 더 제한적인 기능을 수행하는 Observable이다. public typealias Single = PrimitiveSequence public typealias Completable = PrimitiveSequence public struct PrimitiveSequence { let source: Observable init(raw: Observable) { self.source = raw } } 즉, Observable보다 좁은 범위의 기능을 수행하기에, Traits를 사용하지 않고 Observable로 커버가 가능하지만, 코드가 더 명확해진다는 장점이 있다. Single 기존 Observable에서는 next, completed,..
[RxSwift] Operator(2) - Transforming
2022. 12. 27. 18:35
iOS/RxSwift
이번 포스팅에서 살펴볼 연산자는 Observable을 통해 방출되는 item들을 변형해주는 연산자에 대해 알아보자. toArray onCompleted 이벤트 전까지, next 이벤트를 통해 전달된 데이터를 배열로 묶어 한번에 방출한다. toArray() 연산자를 거치게 되면, Single 타입으로 바뀌게 된다. Single 타입은 success, failture이벤트만 전달하기 때문에, subscribe 메서드에서 onCompleted, onNext 가 아닌 onSuccess, onFailure를 통해 이벤트를 받는다. let publish = PublishSubject() publish .toArray() // Single 타입으로 리턴됨. .subscribe( onSuccess: { print($0..
[RxSwift] Operator(1) - Filtering
2022. 12. 25. 15:16
iOS/RxSwift
이번 포스팅에서는 RxSwift의 Operator중에서 Filtering에 관련된 Operator들에 대해 알아보자. Filtering Operator를 통해 next 이벤트를 통해 받는 데이터를 선택적으로 취할 수 있다. Ignoreing Operators ignoreElements() 마블 다이어그램을 보면 알 수 있듯이, next를 통해 전달된 모든 데이터를 무시한다. 여기서 주의할 점은 next를 통해 들어온 이벤트만 무시하고, completed, error 이벤트들은 정상적으로 전달되어 스트림이 끊기게 된다. //Cold Observable의 경우 func observable() -> Observable { return Observable.create { observer in observer.o..
[RxSwift] Subjects
2022. 12. 1. 01:29
iOS/RxSwift
이번 포스팅에서 알아볼 Subject를 알아보기에 앞서, HOT Observable과 COLD Observable에 대해 알아보자! Cold Observable & Hot Observable Cold Observable이란 구독이 되기 전까지 동작하지 않다가, 구독이 되면, 모든 데이터를 한번에 방출한다. Cold Observable을 marble diagram으로 표현하면 아래와 같다.(점선은 구독을 의미한다) 지금까지 알아보았던 Observable이 Cold observable이다. 또한, Unicast방식으로 동작하여, Subscriber(Observer)마다 고유의 Stream이 생성된다. Hot Observable은 구독 여부와 상관없이 방출할 데이터가 있으면 방출한다. 구독이 되면, 모든 데이..
[RxSwift] Observable(2) - Creating Observable
2022. 11. 28. 00:21
iOS/RxSwift
이번 포스팅에는 Observable을 생성하는 Operator 몇 가지에 대해 알아보자! Marble Diagram Operator를 이해하기 앞서, 이 marble diagram에 대해 알 필요가 있다. 실제 ReactiveX에 들어가서 여러 Operator들을 보게 되면, Operator들의 동작을 Marble Diagram을 통해 표현한다. .just() 우선, marble diagram 부터 살펴보자 just 연산자는 marble diagram으로 이해해보면, 데이터가 들어와서(빨간 구슬), Just Operator를 거치게 되면, 데이터를(빨간 구슬)을 방출하는 Observable을 생성하고, 바로 Completed된다. let observable = Observable.just(1) //Obs..
[RxSwift] Observable(1)
2022. 11. 27. 01:03
iOS/RxSwift
이번 포스팅에서는 RxSwift에서 핵심이라고 할 수 있는 Observable에 대해서 알아보자 Observable의 사전적 정의는 "관찰 가능한" 인데, 저번 포스팅에서 말했듯이, Observable은 관찰 가능한 시퀀스를 통해! 이벤트를 방출 한다. 이러한 이유 때문에, RxSwift에서는 이 Observable을 sequence, Observable Sequence라고도 부른다. Observable은 이 이벤트를 방출할때, 비동기로 이벤트를 방출한다! Observable 생명 주기 우선 Observable은 3가지 종류의 이벤트를 방출 할 수 있는데, next error completed 실제 Observable의 이벤트를 보면 @frozen public enum Event { /// Next el..