Форум программистов, компьютерный форум, киберфорум
C# .NET
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.67/6: Рейтинг темы: голосов - 6, средняя оценка - 4.67
3 / 3 / 1
Регистрация: 26.12.2009
Сообщений: 12

Несколько потоков работают с ошибкой

18.04.2010, 07:40. Показов 1117. Ответов 5
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Всем привет. Бьюсь над мультипоточностью уже вторые сутки.

Заранее прошу меня извинить, описать проблему без приведения своего запутанного кода не смог.

В коде приведённом ниже открываются текстовые файлы и разделяются на неповторяющиеся слова. (различные слова)

В один поток все выполняется правильно и без ошибок.

Если запускаю столько потоков, сколько ядер процессора - то, при одинаковых исходных данных - в результате разное количество слов, что по определению невозможно. Либо ошибка (индекс вне границ массива).

Если кому-нибудь не лень разобраться в моём коде и указать на ошибку - буду весьма признателен.


Класс Program.cs - здесь вызываются потоки обрабатывающие файлы:
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
using System;
using System.IO;
using System.Text;
using System.Threading;
namespace DWS_9L
{
    class Program
    {
        public static FileInfo[] textsToRead; // Обрабатываемые файлы
        
        public static int filesNum = 0; // Кол-во обрабатываемых файлов
        public static int finishedFilesNum = 0; // Кол-во обработанных файлов
        
        public static string[][] readedWords = new string[1185922][]; // Этот массив нужно заполнить
        public static int[] readedWordsIndexWordsNum = new int[1185922]; // Кол-во элементов в массивах readedWords[x]
        public static bool[] levelBlocked = new bool[1185922];
        
        public static int Main(string[] args)
        {
            DirectoryInfo bookDir = new DirectoryInfo("./texts");
            textsToRead = bookDir.GetFiles();
            filesNum = textsToRead.Length;
            
            for(int i=0; i<1185922; i++){
                readedWordsTreeLevelWordsNum[i] = 0;
                levelBlocked[i] = false;
            }
            
            int pc = Environment.ProcessorCount;
            
            Splitter[] splitters = new Splitter[pc]; // Создание собственно "обработчиков"
            Thread[] splitterThreads = new Thread[pc];
            
            for(int i=0; i<pc; i++){
             splitters[i] = new Splitter();
            }
            
            for(int i=0; i<pc; i++){
             splitterThreads[i] = new Thread(new ThreadStart(splitters[i].splitWords));
             splitterThreads[i].Priority = ThreadPriority.AboveNormal;
            }
            
            for(int i=0; i<pc; i++){
             splitterThreads[i].Start();
            }
            
            for(int i=0; i<pc; i++){
             splitterThreads[i].Join();
            }
            
            //-- Здесь вывод результатов --
            
            Console.Write("\aPress any key to continue . . . ");
            Console.ReadKey(true);
            return 0;
        }
    }
}
Класс Splitter.cs - собственно обработчик:
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
using System;
using System.IO;
using System.Threading;
namespace DWS_9L
{
    public class Splitter
    {
        public Splitter()
        {
        }
        
        public void splitWords(){
            while(Program.finishedFilesNum < Program.filesNum){ // Узнаём есть ли еще необработанные файлы
                int localFileNum = Program.finishedFilesNum; // Запоминаем номер файла с которым работает поток
                Program.finishedFilesNum++; // Сообщаем остальным потокам, что файл занят
                
                //-- Здесь код, который получает из файла массив слов string outWords[] --
                
                for(int z=0; z < outWords.Length; z++){ // Перебираем слова
                    //-- Здесь код, определяющий int sum - первый индекс массива в который нужно добавить слово
                    
                    bool done = false;
                    while(!done){
                        if(!Program.levelBlocked[sum]){ // Если другие потоки не работают в данный момент с индексом массива [sum]
                            Program.levelBlocked[sum] = true; // Сообщаем остальным потокам, что этот индекс занят
                            
                            if(Program.readedWordsIndexWordsNum[sum] != 0){ // Если в массиве Program.readedWords[sum] есть хоть один элемент
                                bool flag = false; // Флаг, обозначающий - уже добавлено слово в массив или ещё нет
                                for(int y=0; y<Program.readedWordsIndexWordsNum[sum]; y++){ // Ищем слово outWords[z] в массиве Program.readedWords[sum]
                                    if(Program.readedWords[sum][y] == outWords[z]){
                                        flag = true; // Если нашли
                                        break;
                                    }
                                }
                                if(!flag){ // Если слово не найдено - добавляем
                                    string[] tmpString = new string[Program.readedWordsIndexWordsNum[sum]];
                                    tmpString = Program.readedWords[sum];
                                    Program.readedWords[sum] = new string[Program.readedWordsIndexWordsNum[sum] + 1];
                                    tmpString.CopyTo(Program.readedWords[sum], 0);
                                    Program.readedWords[sum][Program.readedWordsIndexWordsNum[sum]] = outWords[z]; // Строка с ошибкой (индекс находился вне границ массива)
                                    Program.readedWordsIndexWordsNum[sum]++;
                                }
                            }
                            else{ // Если в массиве Program.readedWords[sum] нет элементов
                                Program.readedWords[sum] = new string[1];
                                Program.readedWords[sum][0] = outWords[z];
                                Program.readedWordsIndexWordsNum[sum]++;
                            }
                            
                            Program.levelBlocked[sum] = false; // Позволяем остальным потокам работать с этим индеском
                            done = true;
                        }
                    }
                }
            }
        }
    }
}
0
cpp_developer
Эксперт
20123 / 5690 / 1417
Регистрация: 09.04.2010
Сообщений: 22,546
Блог
18.04.2010, 07:40
Ответы с готовыми решениями:

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

Не работают приоритеты потоков
Привет. Подскажите, назначение приоритетов потокам это на столько же бессмысленная затея как и использование yield() для...

Множество потоков работают не намного быстрее одного
Всем привет! Чего-то я залип сегодня на одном месте и решил посоветоваться. Есть многопоточная программа. В программе есть счетчик,...

5
 Аватар для Mikant
1322 / 995 / 127
Регистрация: 08.12.2009
Сообщений: 1,299
18.04.2010, 14:41
да, действительно всё печально( по каждой ошибке описывать - очень долго. прочитай сначала статью Решение 11 распространенных проблем в многопоточном коде (ссылка на которую, между прочим, есть в C#.NET FAQ). я бы предложил весь код переделать, так как он явно не по феншую, ну если лень - то хоть расставить везде lock и Interlocked
1
3 / 3 / 1
Регистрация: 26.12.2009
Сообщений: 12
18.04.2010, 16:38  [ТС]
Спасибо, прочту.

Первый раз использовал многопоточность по такой-же схеме примерно, в другой программе, там все работало. Ну или мне показалось, что работало. Грузило оба ядра на 100 процентов и выполнялось в два раза быстрее.

А пишу не по феншую, это точно. Учусь.
0
 Аватар для Mikant
1322 / 995 / 127
Регистрация: 08.12.2009
Сообщений: 1,299
18.04.2010, 16:42
=) в общем, как подправишь - код в студию. там уже вместе остальные ошибки отыщем
0
eugene001
18.04.2010, 17:55
Причем тут многопоточность и загрузка ядер? Уже же проходили,что многопоточность не распределяет загрузку между ядрами. Для этого другие библиотеки существуют.
 Аватар для Mikant
1322 / 995 / 127
Регистрация: 08.12.2009
Сообщений: 1,299
18.04.2010, 22:24
ыыы. ышоадын) "нагрузку между ядрами" ОС распределяет... тока причем тут это? не понять мне...
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
raxper
Эксперт
30234 / 6612 / 1498
Регистрация: 28.12.2010
Сообщений: 21,154
Блог
18.04.2010, 22:24
Помогаю со студенческими работами здесь

Несколько потоков
Опять я и опять вопрос про потоки. :) Я создал поток, в нем у меня выполняется определенный код. Но мне нужно создать еще несколько...

Несколько потоков
Здравствуйте. Растолкуйте, пожалуйста, одну вещь. Допустим имеется массив из 1000 элементов и 3 потока, которые выводят на экран элемент...

Несколько асинхронных потоков
Здравствуйте. listener.BeginAcceptTcpClient( new AsyncCallback(ListnerPort), ...

Функция в несколько потоков
Здравствуйте! У меня есть функция. Но как бы я ее не оптимизировал скорости прибавления не много. Хотелось бы чтобы эта функция...

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


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

Или воспользуйтесь поиском по форуму:
6
Ответ Создать тему
Новые блоги и статьи
Кто-нибудь знает, где можно бесплатно получить настольный компьютер или ноутбук? США.
Programma_Boinc 26.12.2025
Нашел на реддите интересную статью под названием Anyone know where to get a free Desktop or Laptop? Ниже её машинный перевод. После долгих разбирательств я наконец-то вернула себе. . .
Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы, точка.
Programma_Boinc 23.12.2025
Рецензия / Мнение/ Перевод Нашел на реддите интересную статью под названием The Thinkpad X220 Tablet is the best budget school laptop period . Ниже её машинный перевод. Thinkpad X220 Tablet —. . .
PhpStorm 2025.3: WSL Terminal всегда стартует в ~
and_y87 14.12.2025
PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .
Как объединить две одинаковые БД Access с разными данными
VikBal 11.12.2025
Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.
Новый ноутбук
volvo 07.12.2025
Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом
volvo 04.12.2025
Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .
От async/await к виртуальным потокам в Python
IndentationError 23.11.2025
Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .
Поиск "дружественных имён" СОМ портов
Argus19 22.11.2025
Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .
Сколько Государство потратило денег на меня, обеспечивая инсулином.
Programma_Boinc 20.11.2025
Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha
Etyuhibosecyu 20.11.2025
Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2025, CyberForum.ru