Я разрабатываю приложение-словарь, которое имеет много взаимосвязанных таблиц, поэтому, когда пользователь делает запрос, приложение выполняет поиск почти во всех этих таблицах и во многих их полях, что приводит к тяжелым запросам к базе данных и зависанию пользовательского интерфейса.
Итак, как я могу выполнять эти запросы в отдельной задаче асинхронно каждый раз, обновляя пользовательский интерфейс с результатами?
Я видел findAllAsyn c и тому подобное для android версии области, но для. net Я не мог найти никаких альтернатив, я каждый раз пытался повторно инициализировать базу данных, как предлагалось в другом месте Я запускаю asyn c, но почему-то он не работает и выдает ту же ошибку.
System.Exception: 'Realm accessed from incorrect thread.'
Ошибка возникает в ToList (), когда я пытаюсь преобразовать результаты области в обычный список для обработки пользовательского интерфейса, пожалуйста, помогите исправить это поведение
Вот мой код
using Data.Models;
using Microsoft.EntityFrameworkCore.Internal;
using Realms;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Data
{
public class RealmAsync
{
IQueryable<Entry> Entries { get; set; }
public async void Run()
{
Realm RealmDatabase = Realm.GetInstance();
Entries = RealmDatabase.All<Entry>();
var entries = await FindAsync("а", Entries);
Console.WriteLine($"async result async {entries.Count()}");
}
public async Task<IEnumerable<Entry>> FindAsync(string needle, IQueryable<Entry> haystack)
{
var foregroundRealm = Realm.GetInstance();
var haystackRef = ThreadSafeReference.Create<Entry>(haystack);
var filteredEntriesRef = await Task.Run(() =>
{
using (var realm = Realm.GetInstance())
{
var bgHaystack = realm.ResolveReference(haystackRef);
return ThreadSafeReference.Create(bgHaystack.Where(entry => entry.Content.ToLower().StartsWith(needle)));
}
});
var result = foregroundRealm.ResolveReference(filteredEntriesRef).ToArray();
return result;
}
}
Начальный класс модели:
using System.ComponentModel.DataAnnotations.Schema;
using Realms;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System;
namespace Data.Models
{
[Table("entry")]
public class Entry : RealmObject
{
public class EntryType
{
public const byte Word = 1;
public const byte Phrase = 2;
public const byte Text = 3;
};
[Key]
[PrimaryKey]
[Column("entry_id")]
public int Id { get; set; }
[Column("user_id")]
public int UserId { get; set; }
[Column("source_id")]
public int SourceId { get; set; }
[Indexed]
[Column("type")]
public byte Type { get; set; }
[Column("rate")]
public int Rate { get; set; }
[Column("created_at")]
public string CreatedAt { get; set; }
[Column("updated_at")]
public string UpdatedAt { get; set; }
[NotMapped]
public Phrase Phrase { get; set; }
[NotMapped]
public Word Word { get; set; }
[NotMapped]
public Text Text { get; set; }
[NotMapped]
public IList<Translation> Translations { get; }
[NotMapped]
public string Content
{
get {
switch (Type)
{
case EntryType.Phrase:
return Phrase?.Content;
case EntryType.Word:
return Word?.Content;
case EntryType.Text:
return Text?.Content;
}
return "";
}
}
}
}