@@ -144,7 +144,7 @@ public actor QueuedTask<TaskDescription: TaskDescriptionProtocol> {
144
144
/// Whether `cancelToBeRescheduled` has been called on this `QueuedTask`.
145
145
///
146
146
/// Gets reset every time `executionTask` finishes.
147
- nonisolated ( unsafe ) private var cancelledToBeRescheduled : AtomicBool = . init ( initialValue : false )
147
+ private var cancelledToBeRescheduled : Bool = false
148
148
149
149
/// Whether `resultTask` has been cancelled.
150
150
private nonisolated ( unsafe) var resultTaskCancelled: AtomicBool = . init( initialValue: false )
@@ -246,9 +246,9 @@ public actor QueuedTask<TaskDescription: TaskDescriptionProtocol> {
246
246
private func finalizeExecution( ) async -> ExecutionTaskFinishStatus {
247
247
self . executionTask = nil
248
248
_isExecuting. value = false
249
- if Task . isCancelled && self . cancelledToBeRescheduled. value {
249
+ if Task . isCancelled && self . cancelledToBeRescheduled {
250
250
await executionStateChangedCallback ? ( self , . cancelledToBeRescheduled)
251
- self . cancelledToBeRescheduled. value = false
251
+ self . cancelledToBeRescheduled = false
252
252
return ExecutionTaskFinishStatus . cancelledToBeRescheduled
253
253
} else {
254
254
await executionStateChangedCallback ? ( self , . finished)
@@ -263,7 +263,7 @@ public actor QueuedTask<TaskDescription: TaskDescriptionProtocol> {
263
263
guard let executionTask else {
264
264
return
265
265
}
266
- self . cancelledToBeRescheduled. value = true
266
+ self . cancelledToBeRescheduled = true
267
267
executionTask. cancel ( )
268
268
self . executionTask = nil
269
269
}
0 commit comments