Início / coding / Perguntas / 77045906
Accepted
matt
Asked: 2023-09-05 23:42:07 +0800 CST

Cancelamento mútuo de tarefas

  • 772

Aqui está um pequeno banco de testes mostrando duas tarefas que começam ao mesmo tempo, e a que for concluída primeiro cancela a outra:

func startTest() async throws {
    Task { await test() }
    try await Task.sleep(nanoseconds: 1 * NSEC_PER_SEC)
    // comment out this next line to test the timeout
    NotificationCenter.default.post(name: .init("Test"), object: nil)
}

func test() async {
    let notificationTask = Task {
        for await _ in NotificationCenter.default
            .notifications(named: .init("Test"), object: nil)
            .prefix(1) {}
        print("Done waiting for the notification")
    }
    let timeoutTask = Task {
        try await Task.sleep(nanoseconds: 5 * NSEC_PER_SEC)
        notificationTask.cancel()
        print("I timed out and cancelled the notification task")
    }
    await notificationTask.value
    timeoutTask.cancel()
    print("finished!")
}

Como você pode ver, a ideia é que ou recebamos a notificação em 5 segundos, caso em que o cronômetro de cinco segundos é cancelado, ou expiremos em 5 segundos, caso em que a espera pela notificação é cancelada.

Minha pergunta é: existe uma maneira mais clara de expressar isso? Tentei vários grupos de tarefas e formulações assíncronas, mas não encontrei nada. Talvez este seja o caminho "certo", mas de alguma forma irrita.

swift

1 respostas

  1. Best Answer
    1. Faça umTaskGroup
    2. Adicione todas as suas tarefas de "corrida" (podem ser mais de 2!)
    3. Ligue await tg.next()para aguardar o resultado do “vencedor da corrida”
    4. Ligue tg.cancelAll()para cancelar as tarefas pendentes
    5. ???
    6. lucro!
    import Foundation

func startTest() async throws {
    Task { try await test() }
    try await Task.sleep(nanoseconds: 1 * NSEC_PER_SEC)
    // comment out this next line to test the timeout
    NotificationCenter.default.post(name: .init("Test"), object: nil)
}


func test() async throws {
    try await withThrowingTaskGroup(of: Void.self) { group in
        group.addTask { // formerlynotificationTask
            for await _ in NotificationCenter.default
                .notifications(named: .init("Test"), object: nil)
                .prefix(1) {}
            print("Done waiting for the notification")
        }
        
        group.addTask { // formerly "timeoutTask"
            try await Task.sleep(nanoseconds: 5 * NSEC_PER_SEC)
            print("I timed out and cancelled the notification task")
        }
        
        try await group.next() // Wait for the first completed task
        group.cancelAll() // Cancel the rest
    }
    print("finished!")
}

try await startTest()
    • 3

relate perguntas