Михаил Рахманов — Promises, или почему обещания надо выполнять
•
0 likes•245 views
Видео: https://www.youtube.com/watch?v=c8NUE5lB8x8
![Под капотом
var result: Result<T>?
var handlers: [PromiseHandler<T>] = []
let queue = DispatchQueue(label: "promise.queue",
attributes: .concurrent)](https://image.slidesharecdn.com/promisesupdated-161209113732/85/Promises-18-320.jpg)
![Метод combine
combine([promise1, promise2]).then { results in
…
print(results)
}
воспользуемся DispatchGroup](https://image.slidesharecdn.com/promisesupdated-161209113732/85/Promises-25-320.jpg)
![Метод combine
let resultGroup = DispatchGroup()
var objects: [T] = []
let promiseTuple = Promise<[T]>.promiseTuple()
resultGroup.enter()
promise.then { value in
resultGroup.leave()
objects.append(value)
...
}
.error { err in
promiseTuple.reject(err)
}
func combine<T>(q: DispatchQueue,
promises: [Promise<T>]) -> Promise<[T]>
Для каждого promise](https://image.slidesharecdn.com/promisesupdated-161209113732/85/Promises-26-320.jpg)
![Use case No.4
ParseService
func loadRandomSequences() -> Promise<[BeatSequence]> {
return client
.downloadRandomFile()
.then(parseData)
}
func downloadRandomFile() -> Promise<Data> {
return allPFObjectsFromServer()
.then(downloadRandomFileFromPFObjects)
}
ParseClient](https://image.slidesharecdn.com/promisesupdated-161209113732/85/Promises-36-320.jpg)
Михаил Рахманов — Promises, или почему обещания надо выполнять
- 1. Promises
- 2. Поговорим о промисах • Какие проблемы стояли перед создателями? • Что это и зачем они нужны? • Создадим собственные промисы • Используем их в демо-проекте • Рассмотрим их преимущества и недостатки
- 3. Кто придумал промисы? Карл Хьюитт Барбара Лисков Дэниэл Фридман
- 4. Проблемы • Уменьшение задержки при вычислениях на удаленных машинах • Необходимость максимально использовать возможности систем с множеством процессоров
- 5. Идеи • Распараллелить вычисления • Переиспользовать получающийся результат
- 6. АProcess 1: B+ АProcess 2: C+ Process 3: Future A Future A Future B Future C Process Queue Result Future A Result A Result A Futures (H. Baker, C. Hewitt)
- 7. Fork 1: Fork 2: Queue: Promises (B. Liskov, L. Shira) Record Grade Record Grade Record Grade Promise Student A Promise Student B Promise Student C Print Student A Print Student B Print Student C DataBase:
- 8. Стандартная модель Background: Main: Promise Future Show Picture Download Picture Picture
- 9. Как это могло бы выглядеть в коде? let downloadPromise = Promise<UIImage>() let downloadFuture = downloadPromise.future downloadFuture .then { image in self.imageView.image = image } .error { err in … } downloadPromise.resolve(image)
- 10. Разные реализации в разных языках • С++: promise + future • Scala: promise + future • Javascript: только promise • Swift: нет в стандартной библиотеке в PromiseKit - только Promise
- 11. Для нашей реализации Promise == Future Будем использовать единую сущность
- 12. Основные Use-Cases Последовательные операции: Параллельные операции: Record Promise Bank Backend Upload Promise Show alert Local Backend Combined Promise Show user profile
- 13. Последовательные операции func record() -> Promise<RecordSequence> func upload(sequence: RecordSequence) -> Promise<Void> record.then(upload).then { // code showing alert }
- 14. … а как бы это выглядело с callback’ами record { recording in upload(recording) { result, error in if let result = result { // code showing alert } // error handling } }
- 15. Параллельные операции func bankUserInfo() -> Promise<BankUserInfoConfiguration> func localBackendUserInfo() -> Promise<LocalBackendUserInfoConfiguration> combine(localBackendUserInfo, bankUserInfo) .then { local, bank in … show(userInfoConfiguration) }
- 17. Promise Спецификация Операции выполняются сразу же после создания Можно записать результат один раз Ошибка прерывает выполнение всей Выполняется на произвольной очереди Метод combine и другие Метод then - цепочка промисов В любой момент можно получить доступ к результату
- 18. Под капотом var result: Result<T>? var handlers: [PromiseHandler<T>] = [] let queue = DispatchQueue(label: "promise.queue", attributes: .concurrent)
- 19. Конструктор let promise = Promise<Int> { resolve, reject in resolve(someValue) } Closure, которые дергают внутренние методы Promise
- 20. Реализация конструктора init(closure: PromiseClosure<T>) { closure(resolve, receivedError) } func resolve(_ parameter: T) { guard result == nil else { return } result = .resolved(parameter) handlers.forEach { $0(result!) } } Выполняетс я сразу после создания
- 21. Метод then downloadPromise.then { object in return something(object) } нужно продумать несколько вариаций: например, then принимает другой promise в качестве параметра
- 22. Реализация метода then func then(onQueue q: DispatchQueue, closure: (T) throws -> U) -> Promise<U> { } return Promise<U> { resolve, reject in } self.addHandler { result in q.async { switch result { case .resolved(let parameter): resolve(try closure(parameter)) case .rejected(let error): reject(error) } } } Аналогичная реализация метода error
- 23. Делегаты - отдельная история Сложно обернуть в callback Как нам преобразовать их в Promise? Ответ: передаем значение в Promise извне
- 24. Делегаты typealias PromiseTuple<T> (promise: Promise<T>, resolve: (T) -> (), reject : (Error) -> ()) self.delegatePromise = Promise.promiseTuple() func delegateMethod() { delegatePromise.resolve(response) }
- 25. Метод combine combine([promise1, promise2]).then { results in … print(results) } воспользуемся DispatchGroup
- 26. Метод combine let resultGroup = DispatchGroup() var objects: [T] = [] let promiseTuple = Promise<[T]>.promiseTuple() resultGroup.enter() promise.then { value in resultGroup.leave() objects.append(value) ... } .error { err in promiseTuple.reject(err) } func combine<T>(q: DispatchQueue, promises: [Promise<T>]) -> Promise<[T]> Для каждого promise
- 27. Combine (завершение) resultGroup.notify(queue: q) { promiseTuple.resolve(objects) } return promiseTuple.promise Метод combine возвращает promise сразу же, до завершения вычислений
- 28. Иные методы • when: аналогично combine • after: DispatchQueue.asyncAfter • отмена promises == вызов ошибки
- 30. Use case No. 1 Изменение положения девайса Изменение бита
- 31. Use case No. 2 Изменение позиции секвенсора Изменение UI Проигрывание звука
- 32. Use case No.3 Кнопка сохранить Проигрываем 2 квадрата Загружаем на сервер Показываем алерт
- 33. Use case No.3 recordingPromise = sampler.recordBars() .then(parseService.saveSequences) .then { self.view.animateRecord(false) self.view.showAlert(message:…) } .error { … } ViewModel
- 34. Use case No.4 Кнопка загрузить Загружаем случайный бит Передаем его в семплер Показываем алерт
- 35. Use case No.4 downloadingPromise = parseService.loadRandomSequences() .then(sampler.load) .then { self.view.animateDownload(false) self.view.showAlert(message:…) } .error { … } ViewModel
- 36. Use case No.4 ParseService func loadRandomSequences() -> Promise<[BeatSequence]> { return client .downloadRandomFile() .then(parseData) } func downloadRandomFile() -> Promise<Data> { return allPFObjectsFromServer() .then(downloadRandomFileFromPFObjects) } ParseClient
- 37. Когда стоит использовать Promises? • Сложный бекэнд (последовательные/ параллельные запросы) • Много трудоемких операций в бекграунд потоке • Последовательная анимация • Использование promise в качестве контейнера
- 38. Преимущества Promises • Декларативно - весь код находится рядом • Хранит результат для переиспользования • Легко собирать результаты разных операций • Удобно обрабатывать ошибки
- 39. Недостатки Promises • Неудобно отлаживать • Не подходит для непрерывного потока данных • Неочевидная работа с делегатами