Есть класс, выполняющий роль некого общего ресурса:
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, а не иные средства синхронизации.
lock
)? 2) в чем смысл создавать полеint rngValue;
, если вы его перезаписываете при каждом обращении по сути? Почему бы не сделать его просто локальной переменной? А вообще ваша проблема в том, что вы создаете одновременно дваRandom
поля - потому они одно и то же генерируютThread.Sleep(1000);
до того, как отпустите мьютекс, а не после