Digamos que tengo este código
class Duck{ func walk() async { //do something print("walk start") try? await Task.sleep(nanoseconds: UInt64(2e9)) print("walk end") } func quack() async { //do something... print("quack start") try? await Task.sleep(nanoseconds: UInt64(2e9)) print("quack end") } func fly() async{ //do something print("fly start") try? await Task.sleep(nanoseconds: UInt64(2e9)) print("fly end") } } let duck = Duck() Task{ await duck.walk() } Task{ await duck.quack() } Task{ await duck.fly() }esto imprimiría
walk start quack start fly start walk end quack end fly end que entiendo y esperaba. Pero, ¿qué pasa si quiero que esas 3 Task se ejecuten secuencialmente? Digamos que cada Task es creada por el usuario presionando un botón. Quiero que las tareas se pongan en cola en segundo plano y se ejecuten una por una. ¿Hay algo como que pueda poner en cola DispatchWorkItem en DispatchQueue , pero una versión de Task ?
Se me ocurrió una solución, pero no estoy seguro de si esta es una buena manera de implementarla. Como esta implementación potencialmente crea muchas capas de Task en cascada, me pregunto si habría riesgo de desbordamiento de pila o fugas de memoria.
class TaskQueue{ private var currentTask : Task<Void,Never> = Task{} func dispatch(block:@escaping () async ->Void){ let oldTask = currentTask currentTask = Task{ _ = await oldTask.value await block() } } } taskQueue.dispatch { await duck.walk() } taskQueue.dispatch { await duck.quack() } taskQueue.dispatch { await duck.fly() }Aquí está mi implementación actualizada que creo que es más segura que la que publiqué en la pregunta. La parte TaskQueueActor hace todo el trabajo, la envuelvo con una clase externa solo para que sea más clara cuando se llama desde un contexto no asíncrono.
class TaskQueue{ private actor TaskQueueActor{ private var blocks : [() async -> Void] = [] private var currentTask : Task<Void,Never>? = nil func addBlock(block:@escaping () async -> Void){ blocks.append(block) next() } func next() { if(currentTask != nil) { return } if(!blocks.isEmpty) { let block = blocks.removeFirst() currentTask = Task{ await block() currentTask = nil next() } } } } private let taskQueueActor = TaskQueueActor() func dispatch(block:@escaping () async ->Void){ Task{ await taskQueueActor.addBlock(block: block) } } }