快速组合接收器接收值内存泄漏

Question

我很难与Combine打交道。发布者完成后，我想更新一个值，但是每当我更新该值时，都会分配内存并且永远不会消失。

每当我尝试分配图像时，都会出现泄漏。如果我不分配没有泄漏。

编辑：此处可重现的示例：https : //github.com/peterwarbo/MemoryAllocation

这是我的代码的样子：

final class CameraController: ObservableObject {

    private var storage = Set<AnyCancellable>()    
    var image: UIImage?

    func capture(_ image: UIImage) {

        PhotoLibrary.saveImageToTemporaryDirectory(image) // AnyPublisher<URL, Error>
            .zip(PhotoLibrary.saveImage(image, location: self.locationObserver.location) // AnyPublisher<UIImage, Error>)
            .sink(receiveCompletion: { [weak self] (completion) in
                switch completion {
                case let .failure(error):
                    Log.error(error)
                    self?.handleCaptureError(error)
                case .finished: break
                }
            }) { [weak self] (value) in
                print(value.1) // no leak
                self.image = value.1 // leak

            }
            .store(in: &self.storage)
     }
}

我也试过而不是使用sink：

.receive(
    subscriber: Subscribers.Sink(
        receiveCompletion: { [weak self] completion in
            switch completion {
            case let .failure(error):
                Log.error(error)
                self?.handleCaptureError(error)
            case .finished: break
            }
        },
        receiveValue: { value in
            print(value.1) // no leak
            self.image = value.1 // leak            
        }
    )
)

Answer 1

您的代码的一个明显问题是每次capture调用时都会创建和存储一个新管道。这与如何使用Combine相反；您可能根本不使用Combine。使用Combine 的方法是创建一个管道，然后让信息异步地从管道上下来。

您发布了一个示例项目，在该项目中您使用 Future 来引入图像在管道中传递的延迟。在您的项目中，用户从照片库中反复选择图像。同样，在您的项目中，每次选择图像时都会创建并存储一个新管道。我把例子改写如下：

import UIKit
import Combine

class ViewController: UIViewController, UINavigationControllerDelegate {
    let queue = DispatchQueue(label: "Queue", qos: .userInitiated, attributes: [], autoreleaseFrequency: .workItem)
    var image: UIImage?
    var storage: Set<AnyCancellable> = []
    let publisher = PassthroughSubject<UIImage, Never>()
    override func viewDidLoad() {
        super.viewDidLoad()
        self.publisher
            .flatMap {image in
                self.futureMaker(image: image)
            }
            .receive(on: DispatchQueue.main)
            .sink(receiveCompletion: { (completion) in
            }) { (value) in
                print("finished processing image")
                self.image = value
            }
            .store(in: &self.storage)
    }
    @IBAction func didTapPickImage(_ sender: UIButton) {
        let picker = UIImagePickerController()
        picker.delegate = self
        present(picker, animated: true)
    }
    func futureMaker(image: UIImage) -> AnyPublisher<UIImage, Never> {
        Future<UIImage, Never> { promise in
            self.queue.asyncAfter(deadline: .now() + 0.5) {
                promise(.success(image))
            }
        }.eraseToAnyPublisher()
    }
}
extension ViewController: UIImagePickerControllerDelegate {
    func imagePickerController(_ picker: UIImagePickerController, didFinishPickingMediaWithInfo info: [UIImagePickerController.InfoKey : Any]) {
        dismiss(animated: true)
        guard let image = info[UIImagePickerController.InfoKey.originalImage] as? UIImage else { return }
        print("got image")
        self.publisher.send(image)
    }
}

请注意架构：我在 中创建了一次管道，viewDidLoad每当图像到达时，我都会将它传递到同一管道中。可以肯定的是，使用了一些内存，因为我们正在存储一个 UIImage；但它不会以任何不受控制的方式增长，而是以最佳方式趋于平稳。

在反复选择库中的所有图像后，我们使用了 8.4 MB。没问题！

此外，没有剩余的大图像持续存在。查看图像选择器中选择产生的内存，一张图像仍然存在；那是我们的 8.4 MB 中的 2.7 MB：

这正是我们所期望的。