Синхронизация двух потоков с общей переменной

@max_1296 · Регистрация: 19.08.2013

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

добрый вечер, стоит следующая задача:
Напишите программу, в которой первый поток построчно считывает содержимое некоторого текстового файла, последовательно передавая полученные строки второму потоку. Второй поток преобразовывает каждую поступившую строку (приводит все символы к верхнему регистру) и выводит ее на экран. Для обмена данными между потоками использовать глобальную строковую переменную.

написал код, но он увы зацикливается. Правильно ли я пытаюсь синхронизирывать потоки, зацикливание как я понимаю происходит в методе write, не могу додумать условие. спасибо за советы

C#

    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        public string s=" ";
        static object locker = new object();
        public string put;
        private void button1_Click(object sender, EventArgs e)
        {
            OpenFileDialog op = new OpenFileDialog();
            if (op.ShowDialog() == DialogResult.OK)
            {
                put = op.FileName;
                read();
                Parallel.Invoke(read, write);
            }
        }
 
        private void read()
        {
            StreamReader r = new StreamReader(put);
            while (true)
            {
                lock (locker)
                {
                    s = r.ReadLine();
                    if (s == null) break;
                    
                   
                }
            }            
        }
        private void write()
        {
            lock (locker)
            {
                
                while (true)
                {
                    lock (locker)
                    {
                        richTextBox1.Invoke(new Action(() => { richTextBox1.AppendText(s.ToUpper() + '\n'); }));
                       
                    }
                    if (s == null)
                        return;
                }
            }
        }
 
    }

@Spectral-Owl · 22.02.2017, 09:38

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

lock (locker) { while (true) { lock (locker) {

странная конструкция.

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

Правильно ли я пытаюсь синхронизирывать потоки, зацикливание как я понимаю происходит в методе write, не могу додумать условие

странно что там ошибок не происходит, выбрал первый подряд файл, так программе в методе write должена была null в ToUpper перевести, но зависла раньше) а всё почему? потому-что проверка на null после операции.

Я бы сделал по другому, организовал очередь строк, а не одну текущую строку (имеется в виду не строка как переменная, а строка как row текстового файла).

Метод Read накидывает в строку новых подстрок, Метод Write забирает самую первую строку и выводит её на экран.

И уже не по теме, но ради бога, поменяйте имя переменной в котором храниться имя файла. put - это что-то между push и pop сразу, так сказать, две операции над стеком в одном имени. Если что, путь по анлийски - path.

Добавлено через 27 минут
сверху: метод read выполняется дважды:

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

read();
Parallel.Invoke(read, write);

метод write, так как он описан сейчас, если всё произойдёт хорошо, уйдёт в вечный цикл при любом значении строки, отличной от null.

алгоритм адекватно будет работать только если предположить что методы read и write будут по очереди (строго по очереди) выполнять по одной иттерации из их циклов while. в принципе и к этому виду их можно привести, но тогда будут другие проверки, во первых метод read не должен ничего читать пока в переменной значение, отличное от null, во вторых метод write после отображения строки должен устанавливать её в null.

Добавлено через 30 минут
с минимальными изменениями ваш код:

C#

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.IO;
 
namespace ReadFileTest
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        public string s = null;
        static object locker = new object();
        public string put;
        private void button1_Click(object sender, EventArgs e)
        {
            OpenFileDialog op = new OpenFileDialog();
            if (op.ShowDialog() == DialogResult.OK)
            {
                put = op.FileName;
 
                new System.Threading.Thread(read).Start();
                new System.Threading.Thread(write).Start();
            }
        }
 
        bool reading = false;
        private void read()
        {
            reading = true;
            StreamReader r = new StreamReader(put);
            while (!r.EndOfStream)
            {
                lock (locker)
                {
                    if (s == null)
                        s = r.ReadLine();
                }
            }
            reading = false;
        }
        private void write()
        {
            while (reading)
            {
                lock (locker)
                {
                    if (s != null)
                    {
                        Invoke(new MethodInvoker(AppendString));
                        s = null;
                    }
 
                }
            }
        }
        private void AppendString()
        {
            richTextBox1.AppendText(s.ToUpper() + '\n');
        }
    }
}

@max_1296 · 22.02.2017, 09:53 **[ТС]**

Огромное спасибо. если не трудно можете показать как реализовать тоже самое с AutoResetEvent ?

@Spectral-Owl · 23.02.2017, 10:36

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

если не трудно можете показать как реализовать тоже самое с AutoResetEvent

нет))

@kutyamb · 09.05.2018, 13:02

Извините, а что делать дальше? Программа запустилась, как теперь можно реализовать синхронизацию двух потоков?

@max_1296 2 / 2 / 3 Регистрация: 19.08.2013 Сообщений: 100
	22.02.2017, 09:53 [ТС]	3
	Огромное спасибо. если не трудно можете показать как реализовать тоже самое с AutoResetEvent ? 0

@Spectral-Owl 608 / 583 / 157 Регистрация: 29.06.2010 Сообщений: 1,620
	23.02.2017, 10:36	4
	Сообщение от max_1296 если не трудно можете показать как реализовать тоже самое с AutoResetEvent нет)) 0

@kutyamb 0 / 0 / 0 Регистрация: 22.11.2017 Сообщений: 4
	09.05.2018, 13:02	5
	Извините, а что делать дальше? Программа запустилась, как теперь можно реализовать синхронизацию двух потоков? 0

Опции темы

Синхронизация двух потоков с общей переменной

Решение