@@ -301,6 +301,7 @@ public class FrequencyReader: Reader<[Double]> {
301301private var prev : ( samples: CFDictionary , time: TimeInterval ) ? = nil
302302
303303private let measurementCount : Int = 4
304+ private var isReading : Bool = false
304305
305306private struct IOSample {
306307let group : String
@@ -320,7 +321,8 @@ public class FrequencyReader: Reader<[Double]> {
320321}
321322
322323public override func read( ) {
323- guard !self . eCoreFreqs. isEmpty && !self . pCoreFreqs. isEmpty, self . channels!= nil , self . subscription!= nil else { return }
324+ guard !self . isReading, !self . eCoreFreqs. isEmpty && !self . pCoreFreqs. isEmpty, self . channels!= nil , self . subscription!= nil else { return }
325+ self . isReading= true
324326let minECoreFreq = Double ( self . eCoreFreqs. min ( ) ?? 0 )
325327let minPCoreFreq = Double ( self . pCoreFreqs. min ( ) ?? 0 )
326328
@@ -352,6 +354,7 @@ public class FrequencyReader: Reader<[Double]> {
352354let pFreq : Double = pCores. reduce ( 0 , { $0+ $1} ) / Double( self . measurementCount)
353355
354356self . callback ( [ eFreq, pFreq] )
357+ self . isReading= false
355358}
356359}
357360
@@ -421,7 +424,12 @@ public class FrequencyReader: Reader<[Double]> {
421424
422425for _ in 0 ..< self . measurementCount{
423426let milliseconds = UInt64 ( step) * 1_000_000
424- try ? await Task . sleep ( nanoseconds: milliseconds)
427+ do {
428+ try await Task . sleep ( nanoseconds: milliseconds)
429+ } catch {
430+ if Task . isCancelled{ return [ ] }
431+ continue
432+ }
425433
426434guard let next= self . getSample ( ) else { continue }
427435