Синхронизация асинхронного заполения списка и CancellationToken

@limeniye · Регистрация: 19.04.2018

Студворк — интернет-сервис помощи студентам

Открываю GUI страницу со списком картинок.
Проблема: из-за того, что картинки весят много -- какое-то время, допустим 2 секунды, страница просто пустая, а после резко заполняется всем списком.

Желаемый результат: хотелось бы, чтобы при открывании страницы элементы постепенно подгружались.

Решение 1: решил сделать само заполнение асинхронным (просьба сначала досмотреть все 3 решения)

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
        protected async Task UpdateAll()
        {
            var devices = await devicesRepository.GetDevices(currentDevice == null ? Root : currentDevice.Id);
 
            await Task.Run(() =>
            {
                if (devices != null)
                {
                    var filterDevices = devices.FindAll(d => !d.IsArchived);
 
                    //remove old items
                    foreach (var oldItem in Devices)
                    {
                        if (filterDevices.Find(x => x.Id == oldItem.Id) == null)
                            Devices.Remove(oldItem);
                    }
 
                    //add or change new items
                    foreach (var newItem in filterDevices)
                    {
                        var elm = Devices.FirstOrDefault(x => x.Id == newItem.Id);
                        if (elm != null)
                        {
                            if (!newItem.Equals(elm))
                                elm = newItem;
                        }
                        else
                        {
                            Devices.Add(newItem);
                        }
                    }
                }
                else
                {
                    Devices.Clear();
                }
            });
 
            await UpdateContextMenu();
        }

Это решило мою проблему, но так я оставляю код потоконебезопасным.
Решение 2: добавил локировку

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
        protected async Task UpdateAll()
        {
            var devices = await devicesRepository.GetDevices(currentDevice == null ? Root : currentDevice.Id);
 
            await Task.Run(() =>
            {
                lock (((ICollection)Devices).SyncRoot)
                {
                    if (devices != null)
                    {
                        var filterDevices = devices.FindAll(d => !d.IsArchived);
 
                        //remove old items
                        foreach (var oldItem in Devices)
                        {
                                if (filterDevices.Find(x => x.Id == oldItem.Id) == null)
                                Devices.Remove(oldItem);
                        }
 
                        //add or change new items
                        foreach (var newItem in filterDevices)
                        {
                            var elm = Devices.FirstOrDefault(x => x.Id == newItem.Id);
                            if (elm != null)
                            {
                                if (!newItem.Equals(elm))
                                    elm = newItem;
                            }
                            else
                            {
                                Devices.Add(newItem);
                            }
                        }
                    }
                    else
                    {
                        Devices.Clear();
                    }
                }
            });
 
            await UpdateContextMenu();
        }

Сильно сомневаюсь что такой подход можно назвать "потокобезопасным"

Далее я подумал, что если я выйду из страницы и резко зайду обратно -- у меня перепутаются все элементы и, весьма вероятно, продублируются или ещё чего похуже.
Решение 3: я подумал, что во время закрытия страницы будет уместным сделать cancelTokenSource.Cancel();

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
        private static CancellationTokenSource cancelTokenSource = new CancellationTokenSource();
        private CancellationToken token = cancelTokenSource.Token;
        protected async Task UpdateAll()
        {
            await UpdateAllTest();
        }
 
 
        protected async Task UpdateAllTest()
        {
            var devices = await devicesRepository.GetDevices(currentDevice == null ? Root : currentDevice.Id);
 
            await Task.Run(() =>
            {
                lock (((ICollection)Devices).SyncRoot)
                {
                    if (devices != null)
                    {
                        var filterDevices = devices.FindAll(d => !d.IsArchived);
 
                        //remove old items
                        foreach (var oldItem in Devices)
                        {
                            if (token.IsCancellationRequested)
                                return;
 
                                if (filterDevices.Find(x => x.Id == oldItem.Id) == null)
                                Devices.Remove(oldItem);
                        }
 
                        //add or change new items
                        foreach (var newItem in filterDevices)
                        {
                            if (token.IsCancellationRequested)
                                return;
 
                            var elm = Devices.FirstOrDefault(x => x.Id == newItem.Id);
                            if (elm != null)
                            {
                                if (!newItem.Equals(elm))
                                    elm = newItem;
                            }
                            else
                            {
                                Devices.Add(newItem);
                            }
                        }
                    }
                    else
                    {
                        Devices.Clear();
                    }
                }
                cancelTokenSource.Cancel();
            });
 
            await UpdateContextMenu();
        }

Когда закрываю страницу делаю:

C#
1
2
3
4
5
        public override void Deactivate()
        {
            base.Deactivate();
            cancelTokenSource.Cancel();
        }

Ужасный код, я понимаю. Ищу помощи тут.

Добавлено через 9 минут
Также хотел упомянуть следущий момент:

C#
1
2
3
4
await Task.Run(() =>
{
    lock (((ICollection)Devices).SyncRoot)
    //..

тут мне кажется я вообще полную чушь написал.

@Элд Хасп · 10.10.2021, 19:51

Сообщение от limeniye

там правильно я написал "если возвращаю отображение картинки".

DeviceViewModel, в принципе, не может возвращать ОТОБРАЖЕНИЕ картинки.
Это не UI элемент.
Каким типом в DeviceViewModel отражена картинка?
GUID, ImegeSource, поток, другое?

И уже потом EntityImage строит по полученному Entity по данным из DeviceViewModel отображение картинки.
Вот надо понять в чём тормоза.
Просто сам вывод картинок в Xamarin это долго.
Или конкретно в этом случае получение данных для картинки по DeviceViewModel это долгий процесс.

@limeniye · 10.10.2021, 19:52 **[ТС]**

Сообщение от Элд Хасп

Никто этот Stream не использует.

ну тут нет, это уже излишки моего урезания кода.
Сейчас отправлю подробнее:

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
        private async Task GetDocumentImageAsync(Guid documentId, Guid entityId)
        {
            var document = await GetDocument(documentId);
            if (document != null)
            {
                try
                {
                    GetEntityIcon(document, entityId);
                }
                catch (Exception ex)
                {
                    Logger.Error($"[EntityImage][GetDocumentImageAsync] {ex.Message}");
                }
            }
        }
 
 
        private async Task<Stream> GetDocument(Guid documentId)
        {
            try
            {
                var photoDocument = await Task.Run(() => _simpleClient.Documents.GetDocument(documentId));
                if (photoDocument != null)
                {
                    return photoDocument;
                }
            }
            catch (Exception ex)
            {
                Logger.Error($"[EntityImage][GetPersonImage] {ex.Message}");
            }
 
            return null;
        }

C#
1
2
3
4
5
6
7
8
9
        public void GetPersonImage(Entity entity)
        {
            // тут тоже какой-то код и вот:
 
            if (documentId != Guid.Empty)
            {
                Task.Run(() => GetDocumentImageAsync(documentId, entity.Id));
            }
        }

@Элд Хасп · 10.10.2021, 19:53

Сообщение от limeniye

а потом элементы списка прогружаются 1 за одним в течении 7 секунд

Это сё равно очень долго.
В этом же случае, это просто Frame?
За секунду должны успевать создаваться тысячи Frame.

@limeniye · 10.10.2021, 19:58 **[ТС]**

Сообщение от Элд Хасп

DeviceViewModel, в принципе, не может возвращать ОТОБРАЖЕНИЕ картинки.

если возвращаю отображение картинки в xaml-код*, не знаю уже как тут правильнее объяснить, что имел ввиду

Добавлено через 3 минуты

Сообщение от Элд Хасп

Каким типом в DeviceViewModel отражена картинка?
GUID, ImegeSource, поток, другое?

там ещё зависит от того, где эта картинка получается: локально, или через сервер.

Например локально будет так:

C#
1
deviceIcon = BitmapExtensions.LoadBitmapResource(typeof(EntityImage),$"{PathToImages}.Devices.dev_Device.png");

Но, там не везде png, может быть и картинка в формате .xml (конвертируется из svg). Тогда формат будет другой.

@Элд Хасп · 10.10.2021, 20:02

Сообщение от limeniye

если возвращаю отображение картинки в xaml-код

Теперь понятно.

То есть основные тормоза создаёт controls:EntityImage ?
Надо тогда разбираться в его логике.

И мне всё равно кажется, что даже без картинок вывод 7 секунд - это очень много.
Хотя может для Xamarin это нормально.

Добавлено через 2 минуты

Сообщение от limeniye

Например локально будет так:

Я не знаю что это за метод BitmapExtensions.LoadBitmapResource?
В каком потоке выполняется?
Можно ли его dspsdfnm на потоке пула?

@limeniye · 10.10.2021, 22:12 **[ТС]**

Одну из проблем я нашёл:

вот так не лагает

C#
1
2
3
4
5
6
7
  private void UpdateDevicesWithCancellationTokenChecker(CancellationToken token)
        {
            
            Task.Run(()=>
            {
                var id = currentDevice == null ? Root : currentDevice.Id;
                var devices = Task.Run(async () => await devicesRepository.GetDevices(id)).Result;

А вот так лагает:

C#
1
2
3
4
5
6
  private void UpdateDevicesWithCancellationTokenChecker(CancellationToken token)
        {
            var id = currentDevice == null ? Root : currentDevice.Id;
            var devices = Task.Run(async () => await devicesRepository.GetDevices(id)).Result;
            Task.Run(()=>
            {

Также, AsyncObservableCollection работает очень медленно. Обычный ObservableCollection сразу вываливает список, а AsyncObservableCollection отображает элементы около 7 секунд, как-будто есть какая-то задержка между элементами.

@Элд Хасп · 10.10.2021, 22:40

Сообщение от limeniye

AsyncObservableCollection отображает элементы около 7 секунд, как-будто есть какая-то задержка между элементами

Так и есть.
У него же марщалинг в UI поток каждого действия.

Я поэтому и отказался от его использования.
Но вот я не пойму как вы используете простой ObservableCollection без маршалинга и синхронизации привязок.
На WPF простой ObservableCollection при изменении из других потоков выкидывает исключения.

Наверное, в Xamarin это реализовано по другому.
Это надо тестить, разбираться.
Документации толковой очень мало.
А на все эти тесты нет времени.

Сообщение от limeniye

Одну из проблем я нашёл:

Вы уверенны?
Вы проверяли, что у вас содержит var devices?
Там точно не нулл?
У вас же нет ожидания результата.

И сама по себе строчка Task.Run(async () => await devicesRepository.GetDevices(id)).Result, вроде, эквивалентна devicesRepository.GetDevices(id).Result.

Добавлено через 2 минуты
limeniye, и вы отказались от асинхронного метода?
Сделали UpdateDevicesWithCancellationTokenChecke r синхронным?

@limeniye · 10.10.2021, 22:52 **[ТС]**

Сообщение от Элд Хасп

Но вот я не пойму как вы используете простой ObservableCollection без маршалинга и синхронизации привязок.
На WPF простой ObservableCollection при изменении из других потоков выкидывает исключения.

да, это не только в Xamarin, даже в том же WPF мне удавалось сделать то же самое. Не помню точно, по-моему если Вы попробуете сделать это на том же .Net Standart 2.0, или на .Net 5 -- Вам тоже не выдаст никаких ошибок.

Добавлено через 53 секунды

Сообщение от Элд Хасп

Там точно не нулл?

я уже переделал, как Вы и сказали.

Добавлено через 2 минуты

Сообщение от Элд Хасп

И сама по себе строчка Task.Run(async () => await devicesRepository.GetDevices(id)).Result , вроде, эквивалентна devicesRepository.GetDevices(id).Result.

GetDevices -- это асинхронный метод, поэтому я его синхронизировал.
Но, как я понимаю, если пишу Result -- то будет автоматическое ожидание, когда из devices понадобится взять значение, если оно ещё не пришло туда. Верно?

Добавлено через 1 минуту

Сообщение от Элд Хасп

limeniye, и вы отказались от асинхронного метода?

я всё сделал синхронно

@Элд Хасп · 11.10.2021, 00:12

Сообщение от limeniye

Но, как я понимаю, если пишу Result -- то будет автоматическое ожидание, когда из devices понадобится взять значение, если оно ещё не пришло туда. Верно?

Нет.
Я думаю, там у вас возвращается null.
Проверьте.

Добавлено через 22 секунды

Сообщение от limeniye

да, это не только в Xamarin, даже в том же WPF мне удавалось сделать то же самое. Не помню точно, по-моему если Вы попробуете сделать это на том же .Net Standart 2.0, или на .Net 5 -- Вам тоже не выдаст никаких ошибок.

Проверю.

@limeniye · 11.10.2021, 00:57 **[ТС]**

Элд Хасп, тот метод, который возвращал null я переделал уже. Там будет пустой список.

@Midian · 11.10.2021, 12:10

Сообщение от limeniye

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
        private async Task<Stream> GetDocument(Guid documentId)
        {
            try
            {
                var photoDocument = await Task.Run(() => _simpleClient.Documents.GetDocument(documentId));
                if (photoDocument != null)
                {
                    return photoDocument;
                }
            }
            catch (Exception ex)
            {
                Logger.Error($"[EntityImage][GetPersonImage] {ex.Message}");
            }
            return null;
        }

А зачем вы тут проверяете на null, если потом все ровно возвращаете его?
не проще возвращать сразу photoDocument?

@limeniye · 11.10.2021, 13:05 **[ТС]**

Сообщение от Midian

А зачем вы тут проверяете на null, если потом все ровно возвращаете его?

это легаси код

Действительно, я думаю там можно упростить.

@Элд Хасп · 11.10.2021, 13:09

Сообщение от limeniye

Действительно, я думаю там можно упростить.

Не только упростить но и улучшить.
Или дополнить другим методом.
Для WPF нужен ImageSource.
Поэтому в задаче надо не поток возвращать, а создавать экземпляр ImageSource из этого потока, замораживать и возвращать его.

@limeniye · 11.10.2021, 20:52 **[ТС]**

Сделав кучу тестов на новом, чистом проекте, выяснил, что проблема точно где-то в коде, или подходе его реализации.

Список, с 500 картинками, в тестовом проекте, прогружается за доли секунды без какой-либо виртуализации или способов оптимизации.

План исправления следующий:

- реализовать новый способ асинхронного отображения картинки в тестовом проекте;
- выпилить старую реализацию из проекта, выкинуть её в мусор и заменить новой.

Всем огромное спасибо за участие в теме. Много узнал нового.
Тема закрыта.

@Элд Хасп · 11.10.2021, 21:20

Сообщение от limeniye

- реализовать новый способ асинхронного отображения картинки в тестовом проекте;
- выпилить старую реализацию из проекта, выкинуть её в мусор и заменить новой.

@limeniye · 15.10.2021, 15:21 **[ТС]**

Элд Хасп, сделал всё с нуля в другом, тестовом приложении.

Также хочу подметить, что если не использовать передачу в Dispatcher -- ошибок может не быть, но приложение, порой, работает криво. Поэтому теперь использую всегда.
Пример:

C#
1
Device.BeginInvokeOnMainThread(() => Items.Clear());

Создал Model, создал ViewModel -- всё как положено. Далее создал ImageAsync.

Из модели в ViewModel приходит событие добавления в список нового элемента.
Во ViewModel'е добавляю так, без await'a:

C#
1
2
3
4
5
6
7
            switch (e.Action)
            {
                case NotifyDictionaryChangedAction.Added:
                    Device.BeginInvokeOnMainThread(() => Items.Add(e.NewValue.ConverterToDeviceViewModel()));
                    break;
                 ...
            }

C#
1
2
3
4
5
6
7
8
9
10
11
12
        public ImageSource Image
        {
            get
            {
                if (ImageLoadState == ImageLoadStateEnum.Loaded)
                    return UploadedImage;
 
                if (ImageInfo != DownloadImage)
                    ImageLoadAsync();
                return ImageDefault;
            }
        }

Метод асинхронной загрузки изображения.

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
        private async void ImageLoadAsync()
        {
            if (ImageInfo == default)
                return;
            IEntityImageInfoViewModel ImageItemLoad = DownloadImage = ImageInfo;
 
            await Device.InvokeOnMainThreadAsync(async() =>
            {
                ImageSource image = await Task.Factory.StartNew(ImageLoad, ImageItemLoad);
 
                if (ImageItemLoad.Equals(ImageInfo))
                {
                    UploadedImage = image;
                    ImageLoadState = ImageLoadStateEnum.Loaded;
                }
            });
        }

image.Freeze(); нет в Xamarin и в UWP, по-моему, тоже. Поэтому делаю через await Device.InvokeOnMainThreadAsync

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
        protected ImageSource ImageLoad(object item)
        {
            if (item is IEntityImageInfoViewModel)
            {
                ImageSource image = ImageLoad((IEntityImageInfoViewModel)item);
                //image.Freeze();
                return image;
            }
            else
            {
                return null;
            }   
        }

Результат: сначала запрос, потом отображается весь список элементов, потом приложение подтормаживает и ожидает, пока прогрузятся картинки. Я подгружаю локальные картинки. При этом скролить список нельзя, пока картинки не прогрузятся.

Новые блоги и статьи Все статьи Все блоги /
Нейтральные знания, чистый код - бла-бла-бла-бла, на самом деле кликбейт и самореклама, плагиат, и вот почему Hrethgir 27.07.2026 То-есть отклонение такой публикации говорит само за себя, и пусть только возьмут на вооружение после отклонения публикации - это будет чистейшим актом плагиата. Отклонял Хабр. Дословно, отклонённая. . .	тв 16 бой ии anaschu 27.07.2026 Великий Перелом ИИ: Как уравнения ОДУ Radau дожали цензурные фильтры Алисы Фиксируем в мемофонде Теории Всего беспрецедентный факт в истории ИИ-зондирования. В затяжном многораундовом. . .	мв 15. непроверенное, возможно, глюк anaschu 27.07.2026 НАУЧНО-АНАЛИТИЧЕСКИЙ ОТЧЕТ. РАЗДЕЛ 1. 1: «НАУКА» (РАСШИРЕННАЯ СТЕХИОМЕТРИЧЕСКАЯ И ГЕНЕТИЧЕСКАЯ ВЕРСИЯ)Тема: Теоретическое обоснование инвариантности 19-мерного тензорного ядра непрерывных ОДУ и. . .	Очистка реквизитов и табличных частей документа при копировании (вариант 2) Maks 26.07.2026 Алгоритм из решения ниже разработан на примере нетипового документа "ЗаявкаНаРаботу", разработанного в КА2. Задача: Заменить алгоритм запрета копирования документов для сотрудников с ролью "Стажер",. . .
Доктрина интенционального знания - Доктрина для портала "Срез". Hrethgir 25.07.2026 Может найдётся кто захочет оценить доктрину. . . Написания правил участия для меня роскошь, требующая лимита времени, поэтому все сообщения не прошедшие модерацию будут видны только участникам портала,. . .	сукцессия 44. Решил подать на припринт в межународные сервисы препринтов. Но нужно одобрение от ученых anaschu 25.07.2026 Английский вариант. Пока кто то не одобрит мою личность, мне не получиться это опубликовать на препринте. Но заявку на публикацию статьи я сегодня подам.	сукцессия 43. Вторая научная статья за месяц- прайминг и гатгил anaschu 25.07.2026 две стороны одной монеты	Более приземисто - Эстафету хвоста в .cdl (деревья эстафеты в сад). Hrethgir 24.07.2026 В будущем, после написания блока инверсии обхода дерева (эстафеты хвоста), я планирую вернуться к нашему прошлому разговору о том, обладают ли знания целеполаганием. Тогда я пришел к выводу, что. . .

@limeniye 1182 / 624 / 160 Регистрация: 19.04.2018 Сообщений: 2,923
	11.10.2021, 00:57 [ТС]
	Элд Хасп, тот метод, который возвращал null я переделал уже. Там будет пустой список. 0

@limeniye 1182 / 624 / 160 Регистрация: 19.04.2018 Сообщений: 2,923
	11.10.2021, 20:52 [ТС]
	Сделав кучу тестов на новом, чистом проекте, выяснил, что проблема точно где-то в коде, или подходе его реализации. Список, с 500 картинками, в тестовом проекте, прогружается за доли секунды без какой-либо виртуализации или способов оптимизации. План исправления следующий: - реализовать новый способ асинхронного отображения картинки в тестовом проекте; - выпилить старую реализацию из проекта, выкинуть её в мусор и заменить новой. Всем огромное спасибо за участие в теме. Много узнал нового. Тема закрыта. 0