我有以下收集设备运动数据的类:

class MotionManager: NSObject {
        static let shared = MotionManager()
        private override init() {}

        // MARK: - Class Variables

        private let motionManager = CMMotionManager()

        fileprivate lazy var locationManager: CLLocationManager = {
                var locationManager = CLLocationManager()
                locationManager.delegate = self
                locationManager.desiredAccuracy = kCLLocationAccuracyBest
                locationManager.activityType = .fitness
                locationManager.distanceFilter = 10.0
                return locationManager
        }()

        private let queue: OperationQueue = {
                let queue = OperationQueue()
                queue.name = "MotionQueue"
                queue.qualityOfService = .utility
                return queue
        }()

        fileprivate var motionDataRecord = MotionDataRecord()

        private var attitudeReferenceFrame: CMAttitudeReferenceFrame = .xTrueNorthZVertical

        var interval: TimeInterval = 0.01
        var startTime: TimeInterval?

        // MARK: - Class Functions

        func start() {
                startTime = Date().timeIntervalSince1970
                startDeviceMotion()
                startAccelerometer()
                startGyroscope()
                startMagnetometer()
                startCoreLocation()
        }

        func startCoreLocation() {
                switch CLLocationManager.authorizationStatus() {
                case .authorizedAlways:
                        locationManager.startUpdatingLocation()
                        locationManager.startUpdatingHeading()
                case .notDetermined:
                        locationManager.requestAlwaysAuthorization()
                case .authorizedWhenInUse, .restricted, .denied:
                        break
                }
        }

        func startAccelerometer() {
                if motionManager.isAccelerometerAvailable {
                        motionManager.accelerometerUpdateInterval = interval
                        motionManager.startAccelerometerUpdates(to: queue) { (data, error) in
                                if error != nil {
                                        log.error("Accelerometer Error: \(error!)")
                                }
                                guard let data = data else { return }
                                self.motionDataRecord.accelerometer = data
                        }
                } else {
                        log.error("The accelerometer is not available")
                }

        }

        func startGyroscope() {
                if motionManager.isGyroAvailable {
                        motionManager.gyroUpdateInterval = interval
                        motionManager.startGyroUpdates(to: queue) { (data, error) in
                                if error != nil {
                                        log.error("Gyroscope Error: \(error!)")
                                }
                                guard let data = data else { return }
                                self.motionDataRecord.gyro = data
                        }
                } else {
                        log.error("The gyroscope is not available")
                }
        }

        func startMagnetometer() {
                if motionManager.isMagnetometerAvailable {
                        motionManager.magnetometerUpdateInterval = interval
                        motionManager.startMagnetometerUpdates(to: queue) { (data, error) in
                                if error != nil {
                                        log.error("Magnetometer Error: \(error!)")
                                }
                                guard let data = data else { return }
                                self.motionDataRecord.magnetometer = data
                        }
                } else {
                        log.error("The magnetometer is not available")
                }
        }

        func startDeviceMotion() {
                if motionManager.isDeviceMotionAvailable {
                        motionManager.deviceMotionUpdateInterval = interval
                        motionManager.startDeviceMotionUpdates(using: attitudeReferenceFrame, to: queue) { (data, error) in
                                if error != nil {
                                        log.error("Device Motion Error: \(error!)")
                                }
                                guard let data = data else { return }
                                self.motionDataRecord.deviceMotion = data
                                self.motionDataRecord.timestamp = Date().timeIntervalSince1970
                                self.handleMotionUpdate()
                        }
                } else {
                        log.error("Device motion is not available")
                }
        }

        func stop() {
                locationManager.stopUpdatingLocation()
                locationManager.stopUpdatingHeading()
                motionManager.stopAccelerometerUpdates()
                motionManager.stopGyroUpdates()
                motionManager.stopMagnetometerUpdates()
                motionManager.stopDeviceMotionUpdates()
        }

        func handleMotionUpdate() {
                print(motionDataRecord)
        }

}

// MARK: - Location Manager Delegate
extension MotionManager: CLLocationManagerDelegate {

        func locationManager(_ manager: CLLocationManager, didChangeAuthorization status: CLAuthorizationStatus) {
                if status == .authorizedAlways || status == .authorizedWhenInUse {
                        locationManager.startUpdatingLocation()
                } else {
                        locationManager.stopUpdatingLocation()
                }
        }

        func locationManager(_ manager: CLLocationManager, didUpdateLocations locations: [CLLocation]) {
                guard let location = locations.last else { return }
                motionDataRecord.location = location
        }

        func locationManager(_ manager: CLLocationManager, didUpdateHeading newHeading: CLHeading) {
                motionDataRecord.heading = newHeading
        }

}

不过,运行一段时间后,我得到了EXC_BAD_ACCESS。我运行了僵尸工具,结果显示handleMotionUpdate()是调用方的错误。而MotionDataRecord或者它的一些属性正以某种方式被释放。。。
MotionDataRecord是一个struct
struct MotionDataRecord {
    var timestamp: TimeInterval = 0
    var location: CLLocation?
    var heading: CLHeading?
    var motionAttitudeReferenceFrame: CMAttitudeReferenceFrame = .xTrueNorthZVertical
    var deviceMotion: CMDeviceMotion?
    var altimeter: CMAltitudeData?
    var accelerometer: CMAccelerometerData?
    var gyro: CMGyroData?
    var magnetometer: CMMagnetometerData?
}

你知道这是怎么回事吗?
编辑:
已将项目的精简版本添加到githubhere
编辑:
僵尸乐器截图:
swift - 以下代码中造成僵尸的原因是什么-LMLPHP

最佳答案

好吧,我要做一个小小的思考实验来说明这里可能发生的事情。
首先要记住以下几点:
MotionDataRecord是一个几乎完全由引用类型实例属性组成的结构。这将强制结构参与引用计数。
您正在不同的线程上广泛访问此结构的属性。您的locationManager:didUpdateLocations:在主线程上设置motionDataRecord.location,而您的motionManager.startDeviceMotionUpdates在后台线程上设置motionDataRecord.deviceMotion
每次设置结构属性时,都会对结构进行变异。但实际上Swift中并没有结构突变:结构是一种值类型。真正发生的是复制并替换整个结构(僵尸日志中的queue)。
好的,那么在多个同时执行的线程上,您将进入并替换充满引用的结构。每次你这样做,一个结构副本消失,另一个出现。它是一个充满引用的结构,所以这涉及到引用计数。
假设这个过程是这样的:
创建新结构。
通过复制引用,将新结构的引用属性设置为旧结构的引用属性(我们正在更改的引用属性除外)。这里有一些保留和释放,但都是平衡的。
设置要替换的新结构的引用属性。这将保留新值并释放旧值。
将新结构交换到位。
但这些都不是原子的。因此,这些步骤可能会无序运行,相互交错,因为(记住)您有多个线程同时访问结构。想象一下,在另一个线程上,我们访问步骤3和4之间的结构。特别是,在一个线程上的步骤3和4之间,我们在另一个线程上执行步骤1和2。此时,旧结构仍然存在,它引用了我们正在替换的指向垃圾的属性(因为它在第一个线程的步骤3中被释放和释放)。我们试图在垃圾属性上复制。撞车。
所以,简而言之,我建议(1)将MotionDataRecord设置为类而不是结构,(2)理顺线程(至少,在接触MotionDataRecord之前进入CMMotionManager回调中的主线程)。

09-25 16:34