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

@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) необходимого для отправки сообщения.

Новые блоги и статьи Все статьи Все блоги /
[Owen Logic] Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ФедосеевПавел 14.03.2026 Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ВВЕДЕНИЕ Выполняя задание на управление насосной группой заполнения резервуара,. . .	делаю науч статью по влиянию грибов на сукцессию anaschu 13.03.2026 прикрепляю статью	SDL3 для Desktop (MinGW): Создаём пустое окно с нуля для 2D-графики на SDL3, Си и C++ 8Observer8 10.03.2026 Содержание блога Финальные проекты на Си и на C++: hello-sdl3-c. zip hello-sdl3-cpp. zip Результат:	Установка CMake и MinGW 13.1 для сборки С и C++ приложений из консоли и из Qt Creator в EXE 8Observer8 10.03.2026 Содержание блога MinGW - это коллекция инструментов для сборки приложений в EXE. CMake - это система сборки приложений. Здесь описаны базовые шаги для старта программирования с помощью CMake и. . .
Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки Neotwalker 08.03.2026 Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .	Модульная разработка через nuget packages DevAlt 07.03.2026 Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .	Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .