Как правильно заполнить ObservableCollection в цикле и в потоке?

Question

[SaimonPhoenix]

Есть класс DP:

public class DP
    {
        public string Number { get; set; }
        public string MachineName { get; set; }
        public string UserName { get; set; }
        public string IPAddress { get; set; }
    }

Коллекция oCollectDP:

ObservableCollection<DP> oCollectDP = new ObservableCollection<DP>();

Метод в котором происходит заполнение:

foreach (var item in lstWorkStation) //Список List<string>lstWorkStation
            {
                DP dp = new DP();
                string compName;
                new Thread(()=>
                {
                    compName = item;
                    dp.Number = oCollectDP.Count().ToString();
                    dp.MachineName = compName;
                    dp.UserName = getUserNameWMI(compName);
                    dp.IPAddress = getUserIP(compName);
                    
                    Dispatcher.Invoke(new Action(() =>oCollectDP.Add(dp)));
                }).Start();
            }

Коллекция заполняется, но некорректно (т.е дублируются записи в полях dp.UserName или dp.IPAddress). Как это исправить?

Comments

[Vladimir S]

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

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

[Vladimir S]

и еще думаю лучше сделать заполнение ObservableCollection через промежуточный список типа List

Answer 1

[Tsiren Naimanov]

посмотри методы getUserNameWMi и getUserIP
и зачем поток тебе?
тем более процесс создания потока ресурсоёмкий и не сразу создается в пуле потоков.
попробуй async/await
но точно убери создание потоков
потоки хороши если в них необходимо использовать мат решения, которые зафризят GUI или основной поток.
1. убери создание потоков
2. просмотри методы getUserNameWMI getUserIP

Comments

[SaimonPhoenix]

Без потока заполняется достаточно долго порядка 2-3х минут. В списке lstWorkStation в среднем 250 элементов.

[dordzhiev]

>>потоки хороши если в них необходимо использовать мат решения, которые зафризят GUI или основной поток.

Потоки в принципе плохи, пользуйтесь пулом потоков.

[tex0]

>>Без потока заполняется достаточно долго порядка 2-3х минут
SaimonPhoenix: ну тогда, как написали выше - async/await тебе в помощь

[Tsiren Naimanov]

SaimonPhoenix: ты понимаешь, что если у тебя около 250 элементов, то при итерации foreach ты создаешь 250 глупых потоков, которые не dispose();
ты "а*енно умная ракетчица" мягко говоря

Answer 2

[SaimonPhoenix]

Решил сделать так:

Parallel.ForEach(lstWorkStation, currItem =>
            { 
                DP dp = new DP();

                dp.Number = oCollectDP.Count.ToString();
                dp.MachineName = currItem;
                dp.UserName = getUserNameWMI(currItem);
                dp.IPAddress = getUserIP(currItem);

                Dispatcher.Invoke(new Action(() =>
                {
                    oCollectDP.Add(dp);
                    (sender as BackgroundWorker).ReportProgress(i);
                }));
                i++;
            });

Корректно ли это?

Answer 3

[Larry Underwood]

new Thread().Start() здесь лишний.
i++ нигде не юзается.

Dispatcher.Invoke(new Action(() =>
{
if (oCollectDP.Any(e => e.UserName != dp.UserName && e.IpAddress != dp.IpAddress )) // чтобы избежать дублирования
oCollectDP.Add(dp);
(sender as BackgroundWorker).ReportProgress(i);
}));

Comments

[Vladimir S]

этот способ не избавит от дублирования

[Larry Underwood]

Vladimir S: поясните пожалуйста

[Vladimir S]

if (oCollectDP.Any(e => e.UserName != dp.UserName && e.IpAddress != dp.IpAddress )) oCollectDP.Add(dp);
если коллекция имеет хоть 1-н элемент отличный от добавляемого, то добавляем его в коллекцию.

[SaimonPhoenix]

Хотел бы пояснить один момент по поводу повторяемых(дублируемых) значений. Бывает такая ситуация, что предыдущий UserName или IPAddress записывается на следующую позицию, хотя по факту UserName или IPAddress должны быть другими. По факту повторяемых UserName и IPAddress не должно быть.