0

Есть класс, выполняющий роль некого общего ресурса:

class Source
{
    private static int _count = 0;
    public static Mutex mutex = new Mutex();

    public static void Increment(int value)
    {
        _count += value ;
        Console.WriteLine($"Текущее значение count             {_count}");
    }

    public static void Decrement(int value)
    {
        _count -= value;
        Console.WriteLine($"Текущее значение count             {_count}");
    }
}

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

class MyThread
{
    Thread thread;
    Random rng = new Random();
    int rngValue;

    public MyThread(string name)
    {
        thread = new Thread(this.Run);
        thread.Name = name;
        thread.Start();
    }

    public void Run()
    {
        Console.WriteLine($"Поток {thread.Name} вошел в Run");
        if(thread.Name == "Increment")
        {
            while (true)
            {
                Source.mutex.WaitOne();
                rngValue = rng.Next(10);
                Console.WriteLine($"Сгенерировано число {rngValue}");
                Source.Increment(rngValue);
                Source.mutex.ReleaseMutex();
                Thread.Sleep(1000);
            }
        }
        if(thread.Name == "Decrement")
        {
            while (true)
            {
                Source.mutex.WaitOne();
                rngValue = rng.Next(10);
                Console.WriteLine($"Сгенерировано число -{rngValue}");
                Source.Decrement(rngValue);
                Source.mutex.ReleaseMutex();
                Thread.Sleep(1000);
            }
        }
        else { Console.WriteLine("Неверное имя потока"); }
    }
}

Есть точка входа в программу, где я создаю необходимое мне кол-во потоков:

class Program
{
    static void Main(string[] args)
    {
        MyThread first = new MyThread("Increment");
        MyThread second = new MyThread("Decrement");
        Console.ReadKey();
    }
}

Программа не работает корректно, а именно, не смотря на попытку синхронизации с помощью mutex, потоки все равно работают одновременно. Видимо поэтому значение переменной count всякий раз обращается в ноль, так как потоки decrement increment для вычислений используют одно и тоже случайное число. Вопрос в следующем: как устроить синхронизацию потоков таким образом, чтобы выполнялся только один поток в одну единицу времени, и переменная count не обращалась постоянно в ноль? Использовать необходимо именно mutex. Буду также очень признателен, если укажите ситуации, в которых необходимо использовать именно mutex, а не иные средства синхронизации.

9
  • 1
    1) Почему вы используете Mutex, а не обычный монитор (lock)? 2) в чем смысл создавать поле int rngValue;, если вы его перезаписываете при каждом обращении по сути? Почему бы не сделать его просто локальной переменной? А вообще ваша проблема в том, что вы создаете одновременно два Random поля - потому они одно и то же генерируют
    – tym32167
    Commented 31 окт. 2018 в 11:35
  • Возможный дубликат вопроса: Начальное значение Random() в C#
    – tym32167
    Commented 31 окт. 2018 в 11:36
  • 1
    ну так вы выполните Thread.Sleep(1000); до того, как отпустите мьютекс, а не после
    – tym32167
    Commented 31 окт. 2018 в 12:15
  • 1
    ну, основное, что выделяет мьютекс - это то, что он может быть (а может и не быть) использован для синхронизации между процессами, в то время как, например, монитор - это синхронизация только внутри процесса
    – tym32167
    Commented 31 окт. 2018 в 13:49
  • 1
    Типичный сценарий использования - это, например, запись несколькими процессами в файл, или, например, запуск только 1 экземпляра приложения - обе задачи требуют синхронизации между процессами
    – tym32167
    Commented 31 окт. 2018 в 13:51

1 ответ 1

0

Ваш код корректен, вот результат его выполнения, как видно, значение Count меняется:

введите сюда описание изображения

В рамках одного AppDomain лучше использовать монитор. Он легковестнее.

3
  • Если я закоментирую строки "Сгенерировано число", то раз в секунду буду получать два сообщения о изменении count, хотя должен получать только одно сообщение в секунду Commented 31 окт. 2018 в 12:08
  • Кто вам сказал? Чтобы получать одно сообщение в секунду, вам надо Sleep перенести в обоих if перед ReleaseMutex Commented 31 окт. 2018 в 12:26
  • 1
    Если возьмете инфу из комментариев и скомпонуете шикарный ответ, то я плюсану :)
    – tym32167
    Commented 31 окт. 2018 в 13:59

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.