Семафоры мои семафоры

@karnotavr · Регистрация: 18.02.2022

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

Задача: есть программы Administrator и Writer. Нужно реализовать условие "Одновременно принимать и отправлять сообщения может только два процесса Writer, передача остальных сообщений от других процессов должна блокироваться с помощью семафора". Ниже представлен код на данный момент.

C#

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;
 
namespace Administrator
{
    static class Program
    {
        static void Main(string[] args)
        {
            EventWaitHandle starEvent = new EventWaitHandle(false, EventResetMode.ManualReset, "StarEvent");
            EventWaitHandle hypEvent = new EventWaitHandle(false, EventResetMode.ManualReset, "HypEvent");
            EventWaitHandle terminateEvent = new EventWaitHandle(false, EventResetMode.ManualReset, "TerminateEvent");
 
 
            Console.Write("Enter the number of Writer processes to run: ");
            int numProcesses = int.Parse(Console.ReadLine());
 
            SemaphoreSlim semaphore = new SemaphoreSlim(2, 2);
 
            int numTerminatedProcesses = 0;
 
            Console.WriteLine($"Waiting for {numProcesses} Writer processes to connect...");
 
            ProcessStartInfo startInfo = new ProcessStartInfo();
            startInfo.FileName = @"Writer.exe";
            startInfo.Arguments = "/k";
            startInfo.CreateNoWindow = false;
            startInfo.UseShellExecute = true;
 
            for (int i = 0; i < numProcesses; i++)
            {
                Process process = new Process();
                process.StartInfo = startInfo;
                process.EnableRaisingEvents = true;
            }
 
            while (numTerminatedProcesses < numProcesses)
            {
                semaphore.Wait();
 
                int eventIndex = WaitHandle.WaitAny(new WaitHandle[]
                { starEvent, hypEvent, terminateEvent });
 
                if (eventIndex == 0)
                {
                    Console.Write("*");
                    starEvent.Reset();
                }
                else if (eventIndex == 1)
                {
                    Console.Write("-");
                    hypEvent.Reset();
                }
                else if (eventIndex == 2)
                {
                    semaphore.Release();
                    terminateEvent.Reset();
                    Console.WriteLine("Process terminated");
                }
 
                Console.WriteLine(semaphore.CurrentCount);
            }
 
            semaphore.Dispose();
        }
 
    }
}

И код писателя:

C#

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;
 
namespace Writer
{
    static class Program
    {
        static void Main(string[] args)
        {
            EventWaitHandle starEvent = EventWaitHandle.OpenExisting("StarEvent");
            EventWaitHandle hypEvent = EventWaitHandle.OpenExisting("HypEvent");
            EventWaitHandle terminateEvent = EventWaitHandle.OpenExisting("TerminateEvent");
 
 
            while (true)
            {
                string message = Console.ReadLine();
                if (message == "*")
                {
                    starEvent.Set();
                }
                else if (message == "-")
                {
                    hypEvent.Set();
                }
                else if (message == "end")
                {
                    terminateEvent.Set();
                    break;
                }
            }
        }
    }
}

Проблемы две.

Во-первых, я в упор не понимаю, как нам опустить счетчик семафома до нуля еще при генерации писателей(если их, допустим, 4) и не дать остальным сразу писать сообщения. Ведь если вставить wait() в цикл, то на админе не будут появляться сообщения, что логично, так как быстро уйдет в 0 счетчик.

Во-вторых, непонятно, как блокировать работу конкретного писателя. Поставить wait в админе можно, но зачем. Может, можно передавать семафор в писателя? Как тогда это сделать?

@IamRain · 28.02.2023, 20:20

SemaphoreSlim - это process-wide семафор, то есть он работает только в рамках одного процесса.
Вам либо заменить SemaphoreSlim на Semaphore, либо вместо запуска внешних процессов создавать потоки (Task-и) внутри вашего приложения.

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

как нам опустить счетчик семафома до нуля

Он автоматически опускается при попадании кода в критическую секцию и до вызова Release() метода.
docs

Добавлено через 2 минуты
Что-то мне подсказывает, что вы сами себе усложнили задачу.

@karnotavr · 28.02.2023, 22:00 **[ТС]**

IamRain, Спасибо огромное, читать документацию как всегда оказалось слишком сложно. Ниже для будущих поколений приведу код того, как пофиксил обе проблемы.

Код

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;

namespace Writer
{
    static class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("Connected");
            Semaphore semaphore = Semaphore.OpenExisting("MyNamedSemaphore");
            EventWaitHandle starEvent = EventWaitHandle.OpenExisting("StarEvent");
            EventWaitHandle hypEvent = EventWaitHandle.OpenExisting("HypEvent");
            EventWaitHandle terminateEvent = EventWaitHandle.OpenExisting("TerminateEvent");
            semaphore.WaitOne();

            while (true)
            {
                string message = Console.ReadLine();
                if (message == "*")
                {
                    starEvent.Set();
                }
                else if (message == "-")
                {
                    hypEvent.Set();
                }
                else if (message == "end")
                {
                    semaphore.Release(1);
                    terminateEvent.Set();
                    break;
                }
            }
        }
    }
}

Код

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;

namespace Administrator
{
    static class Program
    {
        static void Main(string[] args)
        {
            EventWaitHandle starEvent = new EventWaitHandle(false, EventResetMode.ManualReset, "StarEvent");
            EventWaitHandle hypEvent = new EventWaitHandle(false, EventResetMode.ManualReset, "HypEvent");
            EventWaitHandle terminateEvent = new EventWaitHandle(false, EventResetMode.ManualReset, "TerminateEvent");

            Console.Write("Enter the number of Writer processes to run: ");
            int numProcesses = int.Parse(Console.ReadLine());



            int numTerminatedProcesses = 0;

            Console.WriteLine($"Waiting for {numProcesses} Writer processes to connect...");

            ProcessStartInfo startInfo = new ProcessStartInfo();
            startInfo.FileName = @"Writer.exe";
            startInfo.Arguments = "/k";
            startInfo.CreateNoWindow = false;
            startInfo.UseShellExecute = true;

            for (int i = 0; i < numProcesses; i++)
            {
                Process process = new Process();
                process.StartInfo = startInfo;
                process.EnableRaisingEvents = true;
                process.Start();
            }

            Semaphore semaphore = new Semaphore(2, 2, "MyNamedSemaphore");

            while (numTerminatedProcesses < numProcesses)
            {
                int eventIndex = WaitHandle.WaitAny(new WaitHandle[]
                { starEvent, hypEvent, terminateEvent });

                if (eventIndex == 0)
                {
                    Console.Write("*");
                    starEvent.Reset();
                }
                else if (eventIndex == 1)
                {
                    Console.Write("-");
                    hypEvent.Reset();
                }
                else if (eventIndex == 2)
                {
                    semaphore.Release(1);
                    terminateEvent.Reset();
                    Console.WriteLine("Process terminated");
                }

            }

            semaphore.Dispose();
        }

    }
}

Блоги программистов
Как перейти с Options API на Composition API в Vue.js BasicMan 06.01.2025 Почему переход на Composition API актуален В мире современной веб-разработки фреймворк Vue. js продолжает эволюционировать, предлагая разработчикам все более совершенные инструменты для создания. . .	Архитектура современных процессоров inter-admin 06.01.2025 Процессор (центральный процессор, ЦП) является основным вычислительным устройством компьютера, которое выполняет обработку данных и управляет работой всех остальных компонентов системы. Архитектура. . .	История создания реляционной модели баз данных, правила Кодда Programming 06.01.2025 Предпосылки создания реляционной модели В конце 1960-х годов компьютерная индустрия столкнулась с серьезными проблемами в области управления данными. Существовавшие на тот момент модели данных -. . .	Полезные поделки на Arduino, которые можно сделать самому raxper 06.01.2025 Arduino как платформа для творчества Arduino представляет собой удивительную платформу для технического творчества, которая открывает безграничные возможности для создания уникальных проектов. Эта. . .	Подборка решений задач на Python IT_Exp 06.01.2025 Целью данной подборки является предоставление возможности ознакомиться с различными задачами и их решениями на Python, что может быть полезно как для начинающих, так и для опытных программистов. . . .	С чего начать программировать микроконтроллеры raxper 06.01.2025 Введение в мир микроконтроллеров Микроконтроллеры стали неотъемлемой частью современного мира, окружая нас повсюду: от простых бытовых приборов до сложных промышленных систем. Эти маленькие. . .
Из чего собрать игровой компьютер inter-admin 06.01.2025 Сборка игрового компьютера требует особого внимания к выбору комплектующих и их совместимости. Правильно собранный игровой ПК не только обеспечивает комфортный геймплей в современных играх, но и. . .	Обновление сайта www.historian.by Reglage 05.01.2025 Обещал подвести итоги 2024 года для сайта. Однако начну с того, что изменилось за неделю. Добавил краткий урок по последовательности действий при анализе вредоносных файлов и значительно улучшил урок. . .	Как использовать GraphQL в C# с HotChocolate Programming 05.01.2025 GraphQL — это современный подход к разработке API, который позволяет клиентам запрашивать только те данные, которые им необходимы. Это делает взаимодействие с API более гибким и эффективным по. . .	Модель полного двоичного сумматора с помощью логических операций (python) AlexSky-coder 04.01.2025 def binSum(x:list, y:list): s=^y] p=x and y for i in range(1,len(x)): s. append((x^y)^p) p=(x and y)or(p and (x or y)) return s x=list() y=list()	Это мы не проходили, это нам не задавали...(асихронный счётчик с управляющим сигналом зад Hrethgir 04.01.2025 Асинхронный счётчик на сумматорах (шестиразрядный по числу диодов на плате, но наверное разрядов будет больше - восемь или шестнадцать, а диоды на старшие), так как триггеры прошли тестирование и. . .	Руководство по созданию бота для Телеграм на Python IT_Exp 04.01.2025 Боты для Телеграм представляют собой автоматизированные программы, которые выполняют различные задачи, взаимодействуя с пользователями через интерфейс мессенджера. В данной статье мы рассмотрим,. . .

@IamRain 3683 / 2594 / 719 Регистрация: 02.08.2011 Сообщений: 6,964
	28.02.2023, 20:20	2
	SemaphoreSlim - это process-wide семафор, то есть он работает только в рамках одного процесса. Вам либо заменить SemaphoreSlim на Semaphore, либо вместо запуска внешних процессов создавать потоки (Task-и) внутри вашего приложения. Сообщение от karnotavr как нам опустить счетчик семафома до нуля Он автоматически опускается при попадании кода в критическую секцию и до вызова Release() метода. docs Добавлено через 2 минуты Что-то мне подсказывает, что вы сами себе усложнили задачу. 1

	28.02.2023, 22:00