Многопоточность при работе с файлами

@fanat2011 · Регистрация: 02.08.2012

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

Доброй ночи!
Написал код для сравнения двух файлов:

C#

            string text, text2;
            bool write = true;
            a = new StreamReader(filePathA);
            b = new StreamReader(filePathB);
            c = new StreamWriter("result.txt");
            while (!a.EndOfStream)
            {
                text = a.ReadLine();
                while (!b.EndOfStream)
                {
                    text2 = b.ReadLine();
                    if (text == text2)
                        write = false;
                }
                b.BaseStream.Position = 0;
                if (write)
                    c.WriteLine(text);
                else
                    write = true;
            }

Как переделать его под многопоточность?
А то даже, если файлы имеют по 10 - 20 к строк программа зависает
Спасибо!

@MrCold · 10.06.2013, 05:59

Как-нибудь так

C#

 public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
 
        Thread thread;
        const string firstpath = "first.txt",
                     secondpath = "second.txt",
                     resultpath = "result.txt";
       
        bool stopcompare = true;
 
        void FileCompare()
        {
            string text, text2;
            bool write = true;
            using (StreamReader first = new StreamReader(firstpath),
                               second = new StreamReader(secondpath))
            using (StreamWriter result = new StreamWriter(resultpath))
                while (!first.EndOfStream && ! stopcompare)
            {
                text = first.ReadLine();
                while (!second.EndOfStream)
                {
                    text2 = second.ReadLine();
                    if (text == text2)
                        write = false;
                }
                second.BaseStream.Position = 0;
                if (write)
                    result.WriteLine(text);
                else
                    write = true;
            }
            stopcompare = true; 
        }
 
        //  КНОПКА СРАВНИТЬ 
        private void button1_Click(object sender, EventArgs e)
        {
            stopcompare = false;
            if (thread == null)
            {
                thread = new Thread(FileCompare);
                thread.Start();
            }
        }
 
        //  КНОПКА ПРЕРВАТЬ
        private void button2_Click(object sender, EventArgs e)
        {           
                stopcompare = true;
                if (thread != null)
                {
                    thread.Abort();
                    thread = null;
                }
        }
    }

@fanat2011 · 10.06.2013, 09:27 **[ТС]**

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

Как-нибудь так

C#

 public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
 
        Thread thread;
        const string firstpath = "first.txt",
                     secondpath = "second.txt",
                     resultpath = "result.txt";
       
        bool stopcompare = true;
 
        void FileCompare()
        {
            string text, text2;
            bool write = true;
            using (StreamReader first = new StreamReader(firstpath),
                               second = new StreamReader(secondpath))
            using (StreamWriter result = new StreamWriter(resultpath))
                while (!first.EndOfStream && ! stopcompare)
            {
                text = first.ReadLine();
                while (!second.EndOfStream)
                {
                    text2 = second.ReadLine();
                    if (text == text2)
                        write = false;
                }
                second.BaseStream.Position = 0;
                if (write)
                    result.WriteLine(text);
                else
                    write = true;
            }
            stopcompare = true; 
        }
 
        //  КНОПКА СРАВНИТЬ 
        private void button1_Click(object sender, EventArgs e)
        {
            stopcompare = false;
            if (thread == null)
            {
                thread = new Thread(FileCompare);
                thread.Start();
            }
        }
 
        //  КНОПКА ПРЕРВАТЬ
        private void button2_Click(object sender, EventArgs e)
        {           
                stopcompare = true;
                if (thread != null)
                {
                    thread.Abort();
                    thread = null;
                }
        }
    }

А как можно добавить несколько потоков?
Софт теперь не завсисает при файлах на 20 - 30 к, но работает очень медленно

@MrCold · 10.06.2013, 09:39

Потоки здесь уже ничем ни помогут . При файлах такого объема скорость работы будет небольшой .

@fanat2011 · 10.06.2013, 15:41 **[ТС]**

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

Потоки здесь уже ничем ни помогут . При файлах такого объема скорость работы будет небольшой .

Тоесть скорость работы нельзя никак увеличить?

И как управлять компонентами в потоках?

C#

       void FileCompare()
        {
            string text, text2;
            bool write = true;
            using (StreamReader first = new StreamReader(filePathA),
                               second = new StreamReader(filePathB))
            using (StreamWriter result = new StreamWriter(filePathResult))
                while (!first.EndOfStream && !stopcompare)
                {
                    text = first.ReadLine();
                    while (!second.EndOfStream)
                    {
                        text2 = second.ReadLine();
                        if (text == text2)
                            write = false;
                    }
                    second.BaseStream.Position = 0;
                    if (write)
                        result.WriteLine(text);
                    else
                        write = true;
                    progressBar1.Increment(1);
                }
            stopcompare = true;
        }

Так не хочет работать, выдает ошибку

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

@MrCold · 10.06.2013, 16:15

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

И как управлять компонентами в потоках?

Не по теме:

Писал на коленке, компутер поломался .Проверять не получается

Передал ProgressBar через ParameterizedThreadStart
Мне кажется без него будет форма подвисать

C#

        void FileCompare(Object Info)
        {
            ProgressBar progressBar = (ProgressBar)Info;
            string text, text2;
            bool write = true;
            using (StreamReader first = new StreamReader(firstpath),
                               second = new StreamReader(secondpath))
            using (StreamWriter result = new StreamWriter(resultpath))
                while (!first.EndOfStream && ! stopcompare)
            {
                text = first.ReadLine();
                while (!second.EndOfStream)
                {
                    text2 = second.ReadLine();
                    if (text == text2)
                        write = false;
                }
                second.BaseStream.Position = 0;
                if (write)
                    result.WriteLine(text);
                else
                    write = true;
 
                    if(progressBar.InvokeRequired)
                        Invoke(new Action(() => progressBar.Increment(1)));
                    else
                        progressBar.Increment(1);
            }
            stopcompare = true; 
        }
 
        //  КНОПКА СРАВНИТЬ 
        private void button1_Click(object sender, EventArgs e)
        {
            stopcompare = false;
            if (thread == null)
            {
                thread = new Thread(new ParameterizedThreadStart(FileCompare));
                thread.Start(progressBar1);
            }
        }
 
        //  КНОПКА ПРЕРВАТЬ
        private void button2_Click(object sender, EventArgs e)
        {           
                stopcompare = true;
                if (thread != null)
                {
                    thread.Abort();
                    thread = null;
                }
        }
 
        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            stopcompare = true;
            if (thread != null)
            {
                thread.Abort();
                thread = null;
            }
        }
    }

@fanat2011 · 11.06.2013, 08:24 **[ТС]**

А как обратится к еще одному компоненту в потоке, например, label?

@Пaтрик · 11.06.2013, 10:19

1 Создаем два потока.
2 В первом потоке вычисляем MD5 первого файла.
3 Во втором потоке вычисляем MD5 второго файла.
4 Сравниваем MD5 двух файлов.

Psilon · 11.06.2013, 21:12

Мне кажется проще поблочно считывать (были дебаты на эту тему тут уже).
Многопоточность тут будет только вредить, потому что у диска только линейное чтение быстрое, если только не ssd. А значит смена контекста будет только тормозить.

Jupiter · 11.06.2013, 21:14

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

Как-нибудь так

BackgroundWorker

@MrCold 873 / 771 / 173 Регистрация: 11.01.2012 Сообщений: 1,942
	10.06.2013, 09:39	4
	Потоки здесь уже ничем ни помогут . При файлах такого объема скорость работы будет небольшой . 1

@fanat2011 13 / 13 / 5 Регистрация: 02.08.2012 Сообщений: 162
	11.06.2013, 08:24 [ТС]	7
	А как обратится к еще одному компоненту в потоке, например, label? 0

@Пaтрик 442 / 410 / 132 Регистрация: 21.01.2012 Сообщений: 974
	11.06.2013, 10:19	8
	1 Создаем два потока. 2 В первом потоке вычисляем MD5 первого файла. 3 Во втором потоке вычисляем MD5 второго файла. 4 Сравниваем MD5 двух файлов. 1

Psilon Master of Orion 6100 / 4956 / 905 Регистрация: 10.07.2011 Сообщений: 14,522 Записей в блоге: 5
	11.06.2013, 21:12	9
	Мне кажется проще поблочно считывать (были дебаты на эту тему тут уже). Многопоточность тут будет только вредить, потому что у диска только линейное чтение быстрое, если только не ssd. А значит смена контекста будет только тормозить. 0

Jupiter Каратель 6610 / 4029 / 401 Регистрация: 26.03.2010 Сообщений: 9,273 Записей в блоге: 1
	11.06.2013, 21:14	10
	Сообщение от MrCold Как-нибудь так BackgroundWorker 0