Форум программистов, компьютерный форум, киберфорум
C# для начинающих
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.86/7: Рейтинг темы: голосов - 7, средняя оценка - 4.86
0 / 0 / 1
Регистрация: 15.04.2013
Сообщений: 184

Создание в background_worker пул потоков

17.02.2015, 20:23. Показов 1373. Ответов 5
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Всем привет!!! столкнулся с проблемой не могу решить, вот допустим мы считываем все текстовые файлы, которые находятся в папке, эту работу удобно переложить на background_worker, а можно ли по мере того как мы находим файлы производить их обработку в thread_pool, при этом чтобы background worker не подвисал, то еcть чтобы он дорабатывал и вызывал бы backgroundWorker1_RunWorkerCompleted, в то время как работа в пулах потоков бы всё ещё шла? написал такой примерно код, но он падает :
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
 private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
        {
            String res = (String)e.Argument;
            var nameFiles = Directory.EnumerateFiles(res);
            int i = 0;
            foreach (string file in nameFiles)
            {
                i++;
                loadFiles(file);
                backgroundWorker1.ReportProgress(i * 5);
            }
}
           private void backgroundWorker1_ProgressChanged(object sender, ProgressChangedEventArgs e)
        {
            progressBar1.Value = e.ProgressPercentage;
            this.Text = e.ProgressPercentage.ToString();
        }
 
        private void backgroundWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
        {
          progressBar1.Value = 100;
         }
 private void loadFiles(string file)
        {
            ManualResetEvent ev = new ManualResetEvent(false);
            MyAsyncInfo info = new MyAsyncInfo();
            info.fileName = file;
            ThreadPool.QueueUserWorkItem((object obj) =>
            {
                callBackLoad(info); // тут загружаем данные в память
                ev.Set();
            });
            ev.WaitOne();
            ManualResetEvent even = new ManualResetEvent(false);
            ThreadPool.QueueUserWorkItem((object obj) =>
            {
                handle(info); // тут обрабатываем данные и сохраняем в другой файл
                even.Set();
            });
            even.WaitOne();
        }
я вообще как понимаю как должен он работать : при вызове метода loadFiles - мы создаем поток который хранит и ожидает пула потоков.
Может кто сталкивался с данной проблемой?
Помогите пожалуйста!!!
Всем спасибо за внимание!!!
0
Programming
Эксперт
39485 / 9562 / 3019
Регистрация: 12.04.2006
Сообщений: 41,671
Блог
17.02.2015, 20:23
Ответы с готовыми решениями:

Создание потоков через пул
Здравствуйте, подскажите пожалуйста вот такое задание для создания потоков используйте пул вот код задачи для потока double x =...

Пул потоков
Здравствуйте. Допустим, у нас есть массив из 1000 элементов и n потоков, которые должны обработать этот массив, но каждый поток должен...

Создать пул потоков
Добрый день. Есть код рабочий, для логирования изменений параметров/связей. Следующий код срабатывает каждый раз по событию сохранения...

5
Эксперт .NET
 Аватар для insite2012
5548 / 4311 / 1218
Регистрация: 12.10.2013
Сообщений: 12,371
Записей в блоге: 2
17.02.2015, 20:29
Цитата Сообщение от Misha_prog Посмотреть сообщение
чтобы background worker не подвисал
А он еще и подвисает?
Цитата Сообщение от Misha_prog Посмотреть сообщение
чтобы он дорабатывал и вызывал бы backgroundWorker1_RunWorkerCompleted
Когда он обработает все что ему задано (или поймает исключение), тогда он и завершит работу с генерацией указанного события.
1
Администратор
Эксперт .NET
 Аватар для OwenGlendower
18298 / 14222 / 5368
Регистрация: 17.03.2014
Сообщений: 28,900
Записей в блоге: 1
17.02.2015, 20:49
Misha_prog, мне кажется ты перемудрил. Т.к. функция loadFiles выполняется в контексте потока для BW и внутри есть ожидание других потоков, то никакой паралельной обработки здесь не будет. Почему бы не сделать так:
C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
    var nameFiles = Directory.EnumerateFiles((string)e.Argument);
    int i = 0;
    foreach (string file in nameFiles)
    {
        ThreadPool.QueueUserWorkItem(loadFiles, file);
        
        i++;
        backgroundWorker1.ReportProgress(i * 5);
    }
}
 
private void loadFiles(object state)
{
    string file = (string)state;
    callBackLoad(file);
    handle(file);
}
1
0 / 0 / 1
Регистрация: 15.04.2013
Сообщений: 184
17.02.2015, 21:04  [ТС]
спасибо за отклики!!!
Цитата Сообщение от insite2012 Посмотреть сообщение
А он еще и подвисает?
извините, глупость написал...

Цитата Сообщение от OwenGlendower Посмотреть сообщение
Почему бы не сделать так:
а background_worker не будет ждать пока отрботают все потоки в пуле, а если не будет ждать то как можно отловить то что всё отработано ?
Спасибо ещё раз за помощь!!!
0
Администратор
Эксперт .NET
 Аватар для OwenGlendower
18298 / 14222 / 5368
Регистрация: 17.03.2014
Сообщений: 28,900
Записей в блоге: 1
17.02.2015, 21:11
Цитата Сообщение от Misha_prog Посмотреть сообщение
а background_worker не будет ждать пока отрботают все потоки в пуле
Метод ThreadPool.QueueUserWorkItem возвращает управление не дожидаясь завершения потока. Соответственно BW тоже ничего ждать не будет.

Цитата Сообщение от Misha_prog Посмотреть сообщение
то как можно отловить то что всё отработано ?
В смысле список всех обработанных файлов? Складывай их в общий List<string>, например:
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
List<string> processedFiles = new List<string>();
 
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
    processedFiles.Clear();
 
    var nameFiles = Directory.EnumerateFiles((string)e.Argument);
    int i = 0;
    foreach (string file in nameFiles)
    {
        ThreadPool.QueueUserWorkItem(loadFiles, file);
        
        i++;
        backgroundWorker1.ReportProgress(i * 5);
    }
}
 
private void loadFiles(object state)
{
    string file = (string)state;
    callBackLoad(file);
    handle(file);
 
    lock (processedFiles) processedFiles.Add(file);
}
1
0 / 0 / 1
Регистрация: 15.04.2013
Сообщений: 184
17.02.2015, 21:14  [ТС]
огромное спасибо!!!!буду пробовать!!!
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
inter-admin
Эксперт
29715 / 6470 / 2152
Регистрация: 06.03.2009
Сообщений: 28,500
Блог
17.02.2015, 21:14
Помогаю со студенческими работами здесь

Создаются не все потоки (пул потоков)
Создаю потоки: for (int i = 0; i &lt; Convert.ToInt32(countPool.Text); i++) { toolStripStatusLabel1.Text =...

Многопоточность, Пул потоков: Запускаются следующие потоки не дождавшись предыдущих
Читаю из файла по строкам некий параметр для передачи в функцию, задаю кол-во потоков, запускаю потоки и нужно дождаться завершения...

Правильно создать пул потоков, запустить эти потоки одновременно и дождаться их завершения
Добрый день! Подскажите пожалуйста, как правильно создать пул потоков, запустить эти потоки одновременно и дождаться завершения всех...

Пул потоков и потоки одновременно
Мне интересно безопасно ли использовать пул потоков и обыкновенные потоки одновременно? Например, пул потоков чисто для общения клиентов с...

Пул потоков и обработка запросов на сервере
Прифет :3 Такой вопрос. Припустим у нас есть недосервер, который изначально принимает подключения и обрабатывает запросы от клиентов в...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
6
Ответ Создать тему
Новые блоги и статьи
Midnight Chicago Blues
kumehtar 24.03.2026
Такой Midnight Chicago Blues, знаешь?. . Когда вечерние улицы становятся ночными, а ты не можешь уснуть. Ты идёшь в любимый старый бар, и бармен наливает тебе виски. Ты смотришь на пролетающие. . .
Контроль уникальности заводского номера - вариант №2
Maks 24.03.2026
В отличие от предыдущего варианта добавлено прерывание циклов, также добавлены новые переменные для сохранения контекста ошибки перед прерыванием цикла: Процедура ПередЗаписью(Отказ, РежимЗаписи,. . .
SDL3 для Desktop (MinGW): Вывод текста со шрифтом TTF с помощью библиотеки SDL3_ttf на Си и C++
8Observer8 24.03.2026
Содержание блога Финальные проекты на Си и на C++: finish-text-sdl3-c. zip finish-text-sdl3-cpp. zip
Жизнь в неопределённости
kumehtar 23.03.2026
Жизнь — это постоянное существование в неопределённости. Например, даже если у тебя есть список дел, невозможно дойти до точки, где всё окончательно завершено и больше ничего не осталось. В принципе,. . .
Модель здравоСохранения: работники работают быстрее после её введения.
anaschu 23.03.2026
geJalZw1fLo Корпорация до введения программа здравоохранения имела много невыполненных работниками заданий, после введения программы количество заданий выросло. Но на выплатах по больничным это. . .
Контроль уникальности заводского номера - вариант №1
Maks 23.03.2026
Алгоритм контроля уникальности заводского (или серийного) номера на примере документа выдачи шин для спецтехники с табличной частью в КА2. Данные берутся из регистра сведений, по которому настроено. . .
Хочу заставить корпорации вкладываться в здоровье сотрудников: делаю мат модель здравосохранения
anaschu 22.03.2026
e7EYtONaj8Y Z4Tv2zpXVVo https:/ / github. com/ shumilovas/ med2. git
Программный отбор элементов справочника по группе
Maks 22.03.2026
Установка программного отбора элементов справочника "Номенклатура" из модуля формы документа в КА2. В качестве фильтра для отбора справочника служит группа номенклатуры. Отбор по наименованию. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru