@@ -9,7 +9,7 @@ public class PendingTask<ResultType: Sendable>: @unchecked Sendable {
99 public typealias ServiceClosure = DefferedTask . TaskClosure
1010 public typealias Completion = DefferedTask . Completion
1111
12- private var mutex : Mutexing = AnyMutex . pthread ( . recursive)
12+ private var mutex : Locking = AnyLock . pthread ( . recursive)
1313 private var cached : DefferedTask ?
1414
1515 private var beforeCallback : Completion ?
@@ -28,7 +28,7 @@ public class PendingTask<ResultType> {
2828 public typealias ServiceClosure = DefferedTask . TaskClosure
2929 public typealias Completion = DefferedTask . Completion
3030
31- private var mutex : Mutexing = AnyMutex . pthread ( . recursive)
31+ private var mutex : Locking = AnyLock . pthread ( . recursive)
3232 private var cached : DefferedTask ?
3333
3434 private var beforeCallback : Completion ?
@@ -53,7 +53,7 @@ public extension PendingTask {
5353 }
5454
5555 func current( _ closure: ( ) -> DefferedTask ) -> DefferedTask {
56- return mutex. sync {
56+ return mutex. syncUnchecked {
5757 let loacalCached : DefferedTask = cached ?? closure ( )
5858 return . init( execute: { [ weak self, loacalCached] actual in
5959 guard let self else {
@@ -78,11 +78,9 @@ public extension PendingTask {
7878 . assign ( to: & self . cached)
7979 . weakify ( )
8080 . onComplete { [ weak self] result in
81- self ? . mutex. sync {
81+ let cachedCallback = self ? . mutex. syncUnchecked {
8282 self ? . cached = nil
83- }
8483
85- let cachedCallback = self ? . mutex. sync {
8684 let originalCallback = self ? . cachedCallback
8785 self ? . cachedCallback = nil
8886 return originalCallback
0 commit comments