Swift Realm в фоновом потоке, то приложение не работает - PullRequest
Новая
       7

Swift Realm в фоновом потоке, то приложение не работает

0 голосов
/ 04 мая 2018

Кажется! Я перепробовал все, но не могу сделать.

Я получаю данные из базы данных через каждые 2 мяты и публикую данные в API. И мое приложение зависает на несколько секунд через каждые 2 мяты. Причина в том, что когда я получаю данные из базы данных, приложение зависает. Я должен сделать в фоновом режиме.

Это мой код работает, но приложение застряло 

 func getObjects(type: Object.Type) -> Results<Object>? {

            //... *****************************
            //...code is working but app is stuck 

            return realm.objects(type)
        }

 if let list = realm.getObjects(type: AssignedCalendars.self)?.filter("isRemove == \(true) AND isSynced == \(false)").toArray(ofType: AssignedCalendars.self) {
                if list.count > 0 {
                    list.forEach({ (calendar) in
                        let calendar_json = [APIKey.event_id : calendar.event_id, APIKey.offlineId: calendar.offlineId, APIKey.calendar_id: calendar.calendar_id.toArray(ofType: Int.self)] as [String: Any]
                        removedCalendars.append(calendar_json)
                    })
                }
                offlineRemovedCalendars.append(contentsOf: list)
                eventData[APIKey.calendar_removelist] = removedCalendars
            }

TRY 1. ПОПРОБУЙТЕ для запуска кода в фоновом режиме, я должен попытаться использовать очередь отправки 

func getObjects(type: Object.Type) -> Results<Object>? {

            //... *****************************
            //...code is working but app is stuck 

            return realm.objects(type)
        }


 DispatchQueue.main.async(execute: {
        if let list = realm.getObjects(type: AssignedCalendars.self)?.filter("isRemove == \(true) AND isSynced == \(false)").toArray(ofType: AssignedCalendars.self) {

            DispatchQueue.global().async {
            if list.count > 0 {
                list.forEach({ (calendar) in
                    let calendar_json = [APIKey.event_id : calendar.event_id, APIKey.offlineId: calendar.offlineId, APIKey.calendar_id: calendar.calendar_id.toArray(ofType: Int.self)] as [String: Any]
                    removedCalendars.append(calendar_json)
                })
            }
            offlineRemovedCalendars.append(contentsOf: list)
            eventData[APIKey.calendar_removelist] = removedCalendars

          } //.. end bac que
        }
        })//... main que

TRY 2. использовать область в фоновом режиме, но я не знаю, как использовать этот метод 

extension Realm {



    func writeAsync<T : ThreadConfined>(obj: T, errorHandler: @escaping ((_ error : Swift.Error) -> Void) = { _ in return }, block: @escaping ((Realm, T?) -> Void)) {
        let wrappedObj = ThreadSafeReference(to: obj)
        let config = self.configuration
        DispatchQueue(label: "background").async {
            autoreleasepool {
                do {
                    let realm = try Realm(configuration: config)
                    let obj = realm.resolve(wrappedObj)

                    try realm.write {
                        block(realm, obj)
                    }
                }
                catch {
                    errorHandler(error)
                }
            }
        }
    }
}

TRY 3. Нашел одно решение, но оно не работает. это не выполнено хорошим способом. Это метод ДОБАВИТЬ, а не получить 

var usersRef: ThreadSafeReference<Results<User>>?
DispatchQueue.global().async {
    autoreleasepool{
        let realm = try! Realm()
        try! realm.write {
            realm.add(users)
        }
        usersRef = ThreadSafeReference(to: users)
    }
}

1 Ответ

0 голосов
/ 04 мая 2018

TRY 1 не работает, потому что вы не можете передать ссылку на объект Realm между потоками. Что вы должны сделать: 

var realmConig: Realm.Configuration = // your config - store it globally

// Now fetch the data
DispatchQueue(label: "background").async {
    // Define a new Realm object inside async thread
    let realm = try! Realm(configuration: realmConfig)
    // now fetch your objects
    let objects = realm.objects(Object.self)
    // From here you can perform actions with the objects
    // i.e. transform if to json format and submit via API
}

Будьте предупреждены : Чтобы использовать objects вне фонового потока, вы должны сначала преобразовать их в массив ThreadSafeReference. Но это не нужно для вашего конкретного случая, насколько я понял ваши цели.

...