Работа с потоками

@allCrowley · Регистрация: 29.11.2014

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

Объясните мне мои ошибки и как их поправить(грузит ЦП и делает невозможным работу с GUI программы - лагает ужасно)
Есть некий класс, в котором происходит работа с потоками - выдержку я представлю ниже. Запускается он из основного потока, вызовом метода CreateThread.

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
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
        private Thread[] Threads;
        public void CreateThread()
        {
            try
            {
                Threads = new Thread[101];
                for (int i = 0; i < 100; i++)
                {
                    Threads[i] = new Thread(this.Worker);
                    Threads[i].IsBackground = true;
                    Threads[i].Start();
                }
 
            }
            catch (Exception)
            {
            }
        }
 
        public void StopThreads()
        {
            try
            {
                for (int i = 0; i < 100; i++)
                {
                    Threads[i].Abort();
                }
            }
            catch (Exception)
            {
            }
        }
 
        public int AliveThreads()
        {
            try
            {
                int count = 0;
                for (int i = 0; i < 100; i++)
                {
                    if (Threads[i].IsAlive)
                    {
                        count++;
                    }
                }
                return count;
            }
            catch
            {
                return 0;
            }
 
        }
 
        void Worker()
        {
            while (SomeQueue1.Count != 0)
            {
                
                if (SomeQueue1.Count + 1 < AliveThreads() && SomeQueue2.Count+1 < AliveThreads())
                {
                    break;
                }
                string data = SomeQueue1.Dequeue();
                try
                {
                    Check(data);
                }
                catch (Exception)
                {
                  SomeQueue.Enqueue(data);
                }
                if (SomeQueue2.Count != 0)
                {
                    string datae = SomeQueue2.Dequeue();
                    try
                    {
                            Check2(datae);
                    }
                    catch (Exception)
                    {
                        SomeQueue2.Enqueue(datae);
                    }
                }
            }

Возможно, моя ошибка в методе обновления GUI. Как вы понимаете,после выполнения Check и Check2 появляются какие-то новые данные, которые я вношу в GUI через таймер, который запускается в самом начале с интервалом в 1000 мс(не из потока же его обноволять, ну). Но что-то я сомневаюсь, что моя проблема в таймере. Скорее всего, я просто неправильно работаю с потоками.

@TopLayer · 22.11.2016, 21:50

Этот код содержит ошибки. Одна из них:

C#
1
2
3
4
                if (SomeQueue2.Count != 0)
                {
                    // здесь нет никаких гарантий, что SomeQueue2 содержит хоть 1 элемент
                    string datae = SomeQueue2.Dequeue();

Насчёт лагов. Они могут быть из-за того, что процессор полностью загружен работой.

@I2um1 · 22.11.2016, 21:56

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

моя ошибка

1. Создаешь 101 поток, но используешь 100. И вообще так много потоков создавать неэффективно. Использовать Thread тоже не эффективно.
2. Производительность просаживается скорее всего из-за try-catch. Писать пустой catch - очень плохая практика.
3. GUI надо обновлять не через таймер, а через методы диспетчера Invoke/BeginInvoke.
4. Потоки работают с общими ресурсами: SomeQueue и SomeQueue2. Необходимо использовать синхронизацию потоков.

Добавлено через 3 минуты
Критической секции для синхронизации потоков должно хватить: используй Monitor, а потом почитай про “стройную” синхронизацию.

@allCrowley · 22.11.2016, 22:41 **[ТС]**

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

Использовать Thread тоже не эффективно.

Если использовать Thread неэффективно, то как еще мне за 5 секунд отправить в сеть 100 запросов и обработать их?

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

2. Производительность просаживается скорее всего из-за try-catch. Писать пустой catch - очень плохая практика.

В некоторых участках кода мне нужно, чтобы ошибки(которые приводят к завершению работы программы) не возникали(иногда они возникают рандомно - на одной и той же операции, с одними и теми же входными данными). Сделать это проще, чем через конструкцию try catch где catch пустой - я не знаю.

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

GUI надо обновлять не через таймер, а через методы диспетчера Invoke/BeginInvoke.

Поправлю, спасибо!

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

Потоки работают с общими ресурсами: SomeQueue и SomeQueue2. Необходимо использовать синхронизацию потоков.

Для чего? Как я понимаю, синхронизировать потоки нужно чтобы не возникало путаницы. Но ее и так не возникает - единственная проблема, это лагающий интерфейс даже на 3-4 потоках.

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

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

C#
1
2
3
4
if (SomeQueue2.Count != 0)
* * * * * * * * {
* * * * * * * * * * // здесь нет никаких гарантий, что SomeQueue2 содержит хоть 1 элемент
* * * * * * * * * * string datae = SomeQueue2.Dequeue();

Почему гарантий нету? Я же условием проверил - если очередь не пустая, то следующий элемент очереди помещаем в datae.

@I2um1 · 22.11.2016, 22:54

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

Если использовать Thread неэффективно, то как еще мне за 5 секунд отправить в сеть 100 запросов и обработать их?

Потоков лучше создавать столько, сколько на компьютере существует физических потоков у процессора. Вместо Thread лучше использовать Task.

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

в сеть 100 запросов

Дефолтное количество соединений 2 (ДВА). Здесь есть кое-какое объяснение https://blogs.msdn.microsoft.c... tionlimit/

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

иногда они возникают рандомно

Они возникают из-за одновременного доступа к общим ресурсам: SomeQueue и SomeQueue2. Эти операции надо синхронизировать с помощью объектов синхронизации.

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

Почему гарантий нету? Я же условием проверил - если очередь не пустая

Допустим первый поток проверяет условие:

C#
1
if (SomeQueue2.Count != 0)

И оно выполняется - в очереди к примеру один элемент.
Далее второй поток выполняет:

C#
1
string datae = SomeQueue2.Dequeue();

Тем самым, когда первый поток дойдет до операции:

C#
1
string datae = SomeQueue2.Dequeue();

И выполнит ее, то произойдет исключение, из-за которого очень сильно падает производительность.

@allCrowley · 23.11.2016, 02:00 **[ТС]**

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

И выполнит ее, то произойдет исключение, из-за которого очень сильно падает производительность.

Понял, спасибо!

@Sanya_sa · 23.11.2016, 03:27

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

Если использовать Thread неэффективно, то как еще мне за 5 секунд отправить в сеть 100 запросов и обработать их?

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
private object ObjLock = new object();
 
void SendMsg(object data)
{
  lock(ObjLock)
  {
      // Тут код отправки сообщения
   }
}
 
 
void Send (datas)
{
    foreach(it in datas)
    {
       ThreadPool.QueueUserWorkItem(SendMsg, (object)it.dataSend);
    }
}

datas- массив из обьектов(data) необходимого для отправки сообщения.

Новые блоги и статьи Все статьи Все блоги /
Отчёт о затраченных материалах за определенный период с макетом печатной формы Maks 21.04.2026 Отчёт из решения ниже размещён в конфигурации КА2. Задача: показать затраченные материалы за определённый период, с возможностью вывода печатной формы отчёта с шапкой и подвалом. В качестве. . .	Отчёт о спецтехнике находящейся в ремонте Maks 20.04.2026 Отчёт из решения ниже размещен в конфигурации КА2. Задача: отобразить спецтехнику, которая на данный момент находится в ремонте. Есть нетиповой документ "Заявка на ремонт спецтехники" который. . .	Памятка для бота и "визитка" для читателей "Semantic Universe Layer (Слой семантической вселенной)" Hrethgir 19.04.2026 Сгенерировано для краткого описания по случаю сборки и компиляции скелета серверного приложения. И пусть после этого скажут, что статьи сгенерированные AI - туфта и не интересно. И это не реклама -. . .	Запрет удаления строк ТЧ документа при определённом условии Maks 19.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "Аккумуляторы", разработанного в конфигурации КА2. У данного документа есть ТЧ, в которой в зависимости от прав доступа. . .
Модель заражения группы наркоманов alhaos 17.04.2026 Условия задачи сформулированы тут Суть: - Группа наркоманов из 10 человек. - Только один инфицирован ВИЧ. - Колются одной иглой. - Колются раз в день. - Колются последовательно через. . .	Мысли в слух. Про "навсегда". kumehtar 16.04.2026 Подумалось тут, что наверное очень глупо использовать во всяких своих установках понятие "навсегда". Это очень сильное понятие, и я только начинаю понимать край его смысла, не смотря на то что давно. . .	My Business CRM MaGz GoLd 16.04.2026 Всем привет, недавно возникла потребность создать CRM, для личных нужд. Собственно программа предоставляет из себя базу данных клиентов, в которой можно фиксировать звонки, стадии сделки, а также. . .	Знаешь почему 90% людей редко бывают счастливыми? kumehtar 14.04.2026 Потому что они ждут. Ждут выходных, ждут отпуска, ждут удачного момента. . . а удачный момент так и не приходит.