Library Moduleordo-one.package-concurrency-helpers 5.1.1PackageConcurrencyHelpers
PackageConcurrencyHelpers
import PackageConcurrencyHelpersModule information
- Declarations
- 33
- Symbols
- 38
import PackageConcurrencyHelpersfunc forBlockingFunc<T>(queue: DispatchQueue = .global(), body: @escaping () -> T) async -> T This function is a helper for calling blocking function from Task and properly suspend the Task while such call take place. The blocking function call happens in global dispatch queue and when it’s done calls continuation to resume suspended Task.
func runSync<T>(priority: TaskPriority? = nil, _ operation: () async throws -> T) throws -> T Runs throwing async closure and waits for its result (incl. rethrowing exception) in non-async code.
func runSync<T>(priority: TaskPriority? = nil, _ operation: () async -> T) -> T Runs async closure and waits for its result in non-async code.
@discardableResult func yieldWithBackPressure<Message>(message: Message, to continuation: AsyncStream<Message>.Continuation) async -> Bool Yields the message to the AsyncStream continuation with back pressure logic.
protocol LockableProtocol any lock can implement.
final class Lock@propertyWrapper final class Protected<T>Thread safe access to simple variable protected by lock
final class SpinlockLock to protect very short critical sections.
final class UnsafeMutableTransferBox<Wrapped>UnsafeMutableTransferBox can be used to make non-Sendable values Sendable and mutable. It can be used to capture local mutable values in a @Sendable closure and mutate them from within the closure. As the name implies, the usage of this is unsafe because it disables the sendable checking of the compiler and does not add any synchronisation.
struct UnsafeSendableWrapper<T>A wrapper that forcefully marks a non-Sendable type as Sendable.
struct UnsafeTransfer<Wrapped>UnsafeTransfer can be used to make non-Sendable values Sendable. As the name implies, the usage of this is unsafe because it disables the sendable checking of the compiler. It can be used similar to @unsafe Sendable but for values instead of types.
import Helpersimport _PauseShims