Многопоточный stremreader

[komra2]

const int BlockSize = 3;
тут любое кол-ство можно вписывать ?

[pu4koff]

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

const int BlockSize = 3;
тут любое кол-ство можно вписывать ?

Да. можно 50 вбить.

[komra2]

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

Да. можно 50 вбить.

Если я хочу, "слить" несколько тхт и потом выполнить этот код, то будет как-то так:

const int BlockSize = 50; // количество строк в блоке

        static void ThreadFunc(object state) // обработка блока строк в отдельном потоке
        {

            var lines = state as IEnumerable<string>;

            foreach (var line in lines) // перебираем строки
            {
                Console.WriteLine("Thread: {0}\tLine: {1}", Thread.CurrentThread.ManagedThreadId, line);
                Console.WriteLine("End thread\tFirst line:{0}\tEndLine:{1}", lines.First(), lines.Last());
            }
        }
        static void Main(string[] args)
        {
            StreamReader sr1 = new StreamReader(@"C:\Users\LowFrequencySound\Desktop\test.txt");
            string aca = sr1.ReadLine();
            foreach (var result in
            from first in File.ReadLines(@"C:\Users\LowFrequencySound\Desktop\1.txt")
            from second in File.ReadLines(@"C:\Users\LowFrequencySound\Desktop\2.txt")
            from third in File.ReadLines(@"C:\Users\LowFrequencySound\Desktop\3.txt")
            from fourth in File.ReadLines(@"C:\Users\LowFrequencySound\Desktop\4.txt")
            from fifth in File.ReadLines(@"C:\Users\LowFrequencySound\Desktop\5.txt")
            from sixth in File.ReadLines(@"C:\Users\LowFrequencySound\Desktop\6.txt")
            select string.Concat(first, second, third, fourth, fifth, sixth))
                using (var reader = new StreamReader(здесь что писать ?))
                {
                    var lines = new List<string>(); // коллекция для сбора блока строк из файла
                    for (; ; )
                    {
                        var str = reader.ReadLine();
                        if (string.IsNullOrEmpty(str)) // файл дочитали до конца
                        {
                            if (lines.Count > 0) // в коллекции остались не отправленные на обработку строки
                            {
                                Console.WriteLine("Start Thread\tFirst line:{0}\tEndLine:{1}", lines[0], lines[lines.Count - 1]);
                                ThreadPool.QueueUserWorkItem(ThreadFunc, lines); // берём поток из пула и выполняем обработку блока строк
                            }
                            break;
                        }
                        lines.Add(str);
                        if (lines.Count == BlockSize) // прочитали нужное число строк из файла, значит можно блок строк отправлять на обработку в другой поток
                        {
                            Console.WriteLine("Start Thread\tFirst line:{0}\tEndLine:{1}", lines[0], lines[lines.Count - 1]);
                            ThreadPool.QueueUserWorkItem(ThreadFunc, lines); // берём поток из пула и выполняем обработку блока строк
                            lines = new List<string>();
                        }
                    }
                }
        }

мне как бы надо чтобы выводился чисто содержимое тхт файлов, мне не надо как бы вот эти :
"Thread: {0}\tLine: {1}"
"End thread\tFirst line:{0}\tEndLine:{1}"
ну кароче без этих console writeline

[Пепел Феникса]

не вижу смысла в чтении по 50 тут.
тут обычный линейный алгоритм.

и ридер тут вообще не нужен, у вас уже есть строки слитые.
смотрите внимательнее на свой foreach.

[pu4koff]

static void Main(string[] args)
        {
            StreamReader sr1 = new StreamReader(@"C:\Users\LowFrequencySound\Desktop\test.txt");
            string aca = sr1.ReadLine();
            var files = new List<string>();
            files.Add(@"C:\Users\LowFrequencySound\Desktop\1.txt");
            files.Add(@"C:\Users\LowFrequencySound\Desktop\2.txt");
            files.Add(@"C:\Users\LowFrequencySound\Desktop\3.txt");
            files.Add(@"C:\Users\LowFrequencySound\Desktop\4.txt");
            files.Add(@"C:\Users\LowFrequencySound\Desktop\5.txt");
            foreach (var filename in files)
            {
                using (var reader = new StreamReader(filename))
                {
                    var lines = new List<string>(); // коллекция для сбора блока строк из файла
                    for (; ; )
                    {
                        var str = reader.ReadLine();
                        if (string.IsNullOrEmpty(str)) // файл дочитали до конца
                        {
                            if (lines.Count > 0) // в коллекции остались не отправленные на обработку строки
                            {
                                Console.WriteLine("Start Thread\tFirst line:{0}\tEndLine:{1}", lines[0], lines[lines.Count - 1]);
                                ThreadPool.QueueUserWorkItem(ThreadFunc, lines); // берём поток из пула и выполняем обработку блока строк
                            }
                            break;
                        }
                        lines.Add(str);
                        if (lines.Count == BlockSize) // прочитали нужное число строк из файла, значит можно блок строк отправлять на обработку в другой поток
                        {
                            Console.WriteLine("Start Thread\tFirst line:{0}\tEndLine:{1}", lines[0], lines[lines.Count - 1]);
                            ThreadPool.QueueUserWorkItem(ThreadFunc, lines); // берём поток из пула и выполняем обработку блока строк
                            lines = new List<string>();
                        }
                    }
                }
             }
        }

[komra2]

а как быть если надо чтобы отображался чисто перебор без таких частей:""Start Thread\tFirst line:{0}\tEndLine:{1}""

[Пепел Феникса]

попробуйте прочитать код, а не тупо копипастить.
очевидно что если не нужно это выводить, то не надо это выводить.

[come-on]

ну тут уже ничего не попишешь, или так или никак
или pu4koff должен переписать всё, вы то врядли справитесь с удалением лишних строк

[komra2]

сделал, только вот не понятно, че делать, если надо больше блоков, ну то есть первый блок берёт 50 строк, а если мне надо 50 блоков..

[komra2]

все равно не склеиваются эти тхт файлы((