以下代码中僵尸的原因是什么
What is the cause of the zombies in the following code
我有以下 class 用于收集设备运动数据:
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?
}
知道这里发生了什么吗?
编辑:
已将项目的精简版本添加到 github here
编辑:
丧尸仪截图:
好的,我将尝试做一个小的思想实验来说明这里可能发生的事情。
首先要记住以下几点:
您的 MotionDataRecord 是一个几乎完全由引用类型实例属性组成的结构。这会强制该结构参与引用计数。
你在不同的线程上疯狂地访问这个结构的属性。您的 locationManager:didUpdateLocations:
在主线程上设置 motionDataRecord.location
,而例如您的 motionManager.startDeviceMotionUpdates
在后台线程 (queue
) 上设置了 motionDataRecord.deviceMotion
。
每次设置结构 属性 时,都会改变结构。但实际上 Swift 中不存在 struct 突变这样的东西:struct 是一种值类型。真正发生的是整个结构被复制和替换(僵尸日志中的initializeBufferWithCopyOfBuffer
)。
好的,所以在多个并发线程上,您将进入并替换您的 struct-full-of-references。每次您这样做时,一个结构副本就会消失,而另一个会出现。这是一个充满引用的结构,所以这涉及到引用计数。
假设流程如下所示:
创建新结构。
通过复制引用将新结构的引用属性设置为旧结构的引用属性(我们正在更改的除外)。这里有一些保留和释放,但它们都平衡了。
设置我们要替换的新结构的引用属性。这会保留新值并释放旧值。
将新结构交换到位。
但是其中的 none 是 atomic。因此,这些步骤可以 运行 乱序,相互交错,因为(记住)你有多个线程同时访问该结构。所以想象一下,在另一个线程上,我们在步骤 3 和 4 之间访问结构。特别是,在一个线程的步骤 3 和 4 之间,我们在另一个线程上执行步骤 1 和 2。在那一刻,旧的结构仍然存在,它引用了我们正在替换的 属性 指向垃圾(因为它在第 3 步的第一个线程中被释放和释放)。我们尝试在垃圾 属性 上进行复制。崩溃。
所以,简而言之,我建议 (1) 使 MotionDataRecord 成为 class 而不是结构,并且 (2) 理顺线程(至少,进入主线程在您触摸 MotionDataRecord 之前在 CMMotionManager 回调中)。
我有以下 class 用于收集设备运动数据:
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?
}
知道这里发生了什么吗?
编辑:
已将项目的精简版本添加到 github here
编辑:
丧尸仪截图:
好的,我将尝试做一个小的思想实验来说明这里可能发生的事情。
首先要记住以下几点:
您的 MotionDataRecord 是一个几乎完全由引用类型实例属性组成的结构。这会强制该结构参与引用计数。
你在不同的线程上疯狂地访问这个结构的属性。您的
locationManager:didUpdateLocations:
在主线程上设置motionDataRecord.location
,而例如您的motionManager.startDeviceMotionUpdates
在后台线程 (queue
) 上设置了motionDataRecord.deviceMotion
。每次设置结构 属性 时,都会改变结构。但实际上 Swift 中不存在 struct 突变这样的东西:struct 是一种值类型。真正发生的是整个结构被复制和替换(僵尸日志中的
initializeBufferWithCopyOfBuffer
)。
好的,所以在多个并发线程上,您将进入并替换您的 struct-full-of-references。每次您这样做时,一个结构副本就会消失,而另一个会出现。这是一个充满引用的结构,所以这涉及到引用计数。
假设流程如下所示:
创建新结构。
通过复制引用将新结构的引用属性设置为旧结构的引用属性(我们正在更改的除外)。这里有一些保留和释放,但它们都平衡了。
设置我们要替换的新结构的引用属性。这会保留新值并释放旧值。
将新结构交换到位。
但是其中的 none 是 atomic。因此,这些步骤可以 运行 乱序,相互交错,因为(记住)你有多个线程同时访问该结构。所以想象一下,在另一个线程上,我们在步骤 3 和 4 之间访问结构。特别是,在一个线程的步骤 3 和 4 之间,我们在另一个线程上执行步骤 1 和 2。在那一刻,旧的结构仍然存在,它引用了我们正在替换的 属性 指向垃圾(因为它在第 3 步的第一个线程中被释放和释放)。我们尝试在垃圾 属性 上进行复制。崩溃。
所以,简而言之,我建议 (1) 使 MotionDataRecord 成为 class 而不是结构,并且 (2) 理顺线程(至少,进入主线程在您触摸 MotionDataRecord 之前在 CMMotionManager 回调中)。