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

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

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

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

C#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
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#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
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, Спасибо огромное, читать документацию как всегда оказалось слишком сложно. Ниже для будущих поколений приведу код того, как пофиксил обе проблемы.

Code
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
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;
                }
            }
        }
    }
}

Code
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
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();
        }
 
    }
}

Новые блоги и статьи Все статьи Все блоги /
Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .	SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D 8Observer8 04.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .	SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий 8Observer8 02.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip Сканируйте QR-код на мобильном и вы увидите, что появится джойстик для управления главным героем. . . .
Реалии Hrethgir 01.03.2026 Нет, я не закончил до сих пор симулятор. Эта задача сложнее. Не получилось уйти в плавсостав, но оно и к лучшему, возможно. Точнее получалось - но сварщиком в палубную команду, а это значит, в моём. . .	Ритм жизни kumehtar 27.02.2026 Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .	SDL3 для Web (WebAssembly): Сборка библиотек: SDL3, Box2D, FreeType, SDL3_ttf, SDL3_mixer и SDL3_image из исходников с помощью CMake и Emscripten 8Observer8 27.02.2026 Недавно вышла версия 3. 4. 2 библиотеки SDL3. На странице официальной релиза доступны исходники, готовые DLL (для x86, x64, arm64), а также библиотеки для разработки под Android, MinGW и Visual Studio. . . .	SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами 8Observer8 20.02.2026 Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .