将阻止功能集成到Swift Async中

Question

我知道异步的Swift 任务不应该阻止（异步工作线程必须始终使进度取得进展）。如果我有其他100％的异步Swift应用程序，但需要引入一些阻止任务，那么做到这一点的正确方法是什么不会阻止任何Swift Async线程池工人？

我假设需要一个新的专用线程在异步线程池外面需要一个假设，如果该假设是正确的，那么线程函数的线程安全方法是什么是等待该线程完成的螺纹函数？我可以使用with checkedContinuation启动线程，复制continuation将其搬运到该线程中，然后调用continuation.resume.resume.resume在该线程完成？

Answer 1

我知道，异步的Swift任务不应该阻止（异步工作线程必须始终取得前进的进度）。

这是正确的。 Swift并发系统的基石是任务必须始终在前进。

我可以使用with checkedContinuation启动线程，将持续句柄复制到该线程中，然后调用连续性。

是的，这也是正确的，正是连续性的目的：

checkedContinuation
同步和异步代码之间接口的机制，记录正确性违规。

延续的目的是使您可以将阻止同步操作拟合到async世界中。当您致电

[s] uspend当前任务，然后通过检查当前任务的检查延续来调用给定的封闭。

该任务无限期地暂停，直到您恢复它为止，这允许其他任务在此期间取得进展。您获得的延续值是一个线程安全接口，以表明您的阻塞操作已经完成，并且原始任务应在下一个可用的机会中恢复。延续还为 sendable ，这表明您可以在线程之间安全地传递它。任何线程都可以恢复任务，因此您甚至不一定需要回到同一线程上的延续。

来自：

func operation() async -> OperationResult {
  // Suspend the current task, and pass its continuation into a closure
  // that executes immediately
  return await withUnsafeContinuation { continuation in
    // Invoke the synchronous callback-based API...
    beginOperation(completion: { result in
      // ...and resume the continuation when the callback is invoked
      continuation.resume(returning: result)
    }) 
  }
}

---

请注意，这仅是真正阻止的任务所必需的，并且在某些方面之前无法取得进一步的进步他们依靠完成。这与执行主动计算的任务不同，这些任务恰好需要很长时间，因为这些任务至少是在积极进步的任务。 （但是在聊天中，您澄清了您的用例是前者。）

Answer 2

你说：

我假设需要在异步线池外面的新专用线程……

我不会得出结论。这完全取决于此“阻止任务”的性质。

1. 如果仅仅是一些缓慢的同步任务（例如，CPU密集型任务），则可以留在Swift并发系统中，并在独立任务或参与者中执行此同步任务。但是，如果这样做，则必须定期 task.yield.yield（） 在此任务中，以确保您履行Swift并发合同以“确保前进进度”。

2. 如果是一些阻止API可以在该线程上等待/睡觉，那么，正如Itai建议的那样，我们将其包裹在延续中，理想情况下，用非阻止api代替该API。如果用异步演绎替换阻止API是不切实际的，那么，是的，您可以为此旋转自己的线程，有效地使其成为异步任务，然后将其包裹在延续中。

---

但是，在长期运行，阻止，计算的背景下，如果一个人不能定期yart， se-0296-异步/等待说一个应该在“单独的上下文”中运行它（重点添加）：

由于潜在的悬架点只能出现在异步函数中明确标记的点处，因此长度计算仍然可以阻止线程。当调用仅执行大量工作的同步函数时，或者遇到直接以异步函数写入的特别激烈的计算循环时，可能会发生这种情况。无论哪种情况，这些计算运行时都无法交织代码，这通常是正确性的正确选择，但也可能成为可扩展性问题。 需要执行强度计算的异步程序通常应在单独的上下文中运行。如果这是不可行的，则将有库设施人为地暂停并允许其他操作进行交织。

>

该提案的长期计算没有能力，这表明一个“在单独的上下文中运行”。例如，在WWDC 2022的 ，Apple明确建议将阻止代码移出Swift并发系统：

一定要避免阻止任务中的呼叫。 …如果您有需要执行这些操作的代码，请在并发线程池之外移动该代码 - 例如，通过在调度值上运行它 - 并使用连续性将其桥接到并发世界。

因此，例如，您可以执行以下操作（假设value是soddable）：

func foo() async -> Value {
    await withCheckedContinuation { continuation in
        DispatchQueue.global(qos: .utility).async {
            let value = slowAndSynchronous()
            continuation.resume(returning: value)
        }
    }
}

另外，如今，您可以使用Actor从Swift并发合作线程池中获取它用

actor Foo {
    private let queue = DispatchSerialQueue(label: Bundle.main.bundleIdentifier! + ".Foo", qos: .utility)

    nonisolated var unownedExecutor: UnownedSerialExecutor {
        queue.asUnownedSerialExecutor()
    }

    func foo() -> Value {
        // you can confirm that you are not in the cooperative thread pool
        //
        // dispatchPrecondition(condition: .onQueue(queue))

        return slowAndSynchronous()
    }
}

href = “ 如果同步函数无法定期产生，允许交错，请通过其中一个将此代码移到合作线程池外上面概述的机制。

请注意，Swift并发无法推理其范围之外的其他线程，并将继续充分利用合作的线程池，从而导致CPU的潜在过度使用（合作线程池旨在解决问题之一）。这是次优的，因此需要一些护理，但是如果您使用迅速并发与阻止或计算密集型库一起设计的没有合作的线程池的设计，则可能是必要的邪恶。