Мьютексы и потоки

@DE00000000 · Регистрация: 06.09.2020

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

Windows
Здравствуйте, при выполнении лр возникает ошибка касаемая синхронизации двух потоков с помощью мьютексов. Исправить никак не получается
Задание: написать тему из нескольких независимых потоков, совместно решающих выборочную дисперсию трех чисел.
Поток выполняет элементарное арифметическое действие.

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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
#include <iostream>
#include <Windows.h>
 
 
 
// MUTEXES
HANDLE MutMul   = CreateMutex(NULL, TRUE, L"MutMul");
 
HANDLE MutMain  = CreateMutex(NULL, TRUE, L"MutMain");
 
 
DWORD WINAPI mul(LPVOID)
{
 
    double data[] = { 0, 0 };
    double end = 0;
 
    HANDLE MutThis = OpenMutex(SYNCHRONIZE, FALSE, L"MutMul");
    HANDLE MutCore = OpenMutex(SYNCHRONIZE, FALSE, L"MutMain");
    // Открытие канала
    HANDLE pipe =
    CreateFileA(
        "\\\\.\\pipe\\pMul",
        GENERIC_READ | GENERIC_WRITE,
        FILE_SHARE_READ | FILE_SHARE_WRITE,
        NULL,
        OPEN_EXISTING,
        FILE_ATTRIBUTE_NORMAL,
        NULL
    );
 
    std::cout << "Результат открытия трубы;" << std::endl;
    std::cout << GetLastError() << std::endl; //дает код ошибки
 
    ReleaseMutex(MutCore);
 
    while (true){
 
        // Ждем данные
        WaitForSingleObject(
            MutThis,
            INFINITE
        );
 
        DWORD rb = 0, wb = 0;
        ReadFile(pipe, data, sizeof(double) * 2, &rb, NULL);
            std::cout << "Результат считывания в потоке;" << std::endl;
            std::cout << GetLastError() << std::endl; //дает код ошибки
 
        end = data[0] * data[1];
 
        WriteFile(pipe, &end, sizeof(double), &wb, NULL);
            std::cout << "Результат записи результата в потоке;" << std::endl;
            std::cout << GetLastError() << std::endl; //дает код ошибки
 
        ReleaseMutex(MutCore);
    }
 
    return 0;
}
 
 
DWORD WINAPI pseudomain(LPVOID){
    
    HANDLE Mut_mul = OpenMutex(SYNCHRONIZE, FALSE, L"MutMul");
    HANDLE Mut_core = OpenMutex(SYNCHRONIZE, FALSE, L"MutMain");
 
    LPCSTR pMulName = "\\\\.\\pipe\\pMul";
    HANDLE pipeMul = CreateNamedPipeA (
        pMulName,
        PIPE_ACCESS_DUPLEX,
        PIPE_TYPE_BYTE,
        PIPE_UNLIMITED_INSTANCES,
        2*sizeof(double),
        sizeof(double),
        NMPWAIT_USE_DEFAULT_WAIT,
        NULL
        );
 
        std::cout << "Результат создания трубы;" << std::endl;
        std::cout<<GetLastError()<<std::endl; //дает код ошибки
 
    // THREADS
    CreateThread(
        NULL,
        0,
        mul,
        NULL,
        0,
        NULL
    );
 
    // Ожидаем открытия канала
    WaitForSingleObject(Mut_core, INFINITE);
 
    // ДАННЫЕ 
    double test[] = {12.0,10.0};    // Result = 120
    double result = 0.0;
 
    DWORD wb = 0, rb = 0;
    WriteFile(pipeMul, test, sizeof(double) * 2, &wb, NULL);
    std::cout << "Результат записи данных в канал;" << std::endl;
            std::cout << GetLastError() << std::endl; //дает код ошибки
 
    // Ждем ответа
    ReleaseMutex(Mut_mul);
 
    //блокируем чтобы выполнить умножение НЕ в главном потоке mul
    WaitForSingleObject(
        Mut_core,
        INFINITE
    );
 
    /// Данные считываются
    ReadFile(pipeMul, &result, sizeof(double), &rb, NULL);
    std::cout << "Получение результата из потока;" << std::endl;
            std::cout << GetLastError() << std::endl; //дает код ошибки
    std::cout << result;
    
 
    system("pause");
    return 0;
}
 
int main()
{
    /// Formula: б = 1/2 * sum((x-average)^2);  average = (x1 + x2 + x3) / 3;
    /// 1. Создать потоки для   /, -, +, *  Thread: (...(x1 ? x2: result)...)
    /// 2. Каналы для каждого потока  (создать->открыть) *use mutex (открыть -/-> создать)
    /// 3. Начать вычисления
 
    setlocale(LC_ALL, "rus");
 
    // THREADS
    CreateThread(
        NULL,
        0,
        pseudomain,
        NULL,
        0,
        NULL
    );
 
    Sleep(5000);
    ReleaseMutex(MutMul);
    ReleaseMutex(MutMain);
 
    return 0;
}

@oleg-m1973 · 28.11.2020, 20:18

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
HANDLE mutex1 = CreateMutex(NULL, FALSE, NULL);
volatile bool stop = false;
volatile bool ready = false;
 
DWORD WINAPI function(LPVOID) 
{
    while (!stop)
    {
        Sleep(1000);
        WaitForSingleObject(mutex1, INFINITE);
        if (!ready)
        {
            ready = true;
            std::cout << "Set ready" << std::endl;
        }
        ReleaseMutex(mutex1);
    }
    return 0;
}
 
int main() 
{
 
    HANDLE thread = CreateThread(NULL, 0, function, NULL, 0, NULL);
 
    for (size_t i = 0; i < 10; )
    {
        WaitForSingleObject(mutex1, INFINITE);
        if (ready)
        {
            ++i;
            ready = false;
            std::cout << "Process ready: " << i << std::endl;
            
        }
        ReleaseMutex(mutex1);
        Sleep(1000);
    }
 
    stop = true;
    WaitForSingleObject(thread, INFINITE);
    return 0;
 
}

@JeyCi · 29.11.2020, 07:40

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

H – каналы;

а разве это есть в коде?..

Не по теме:

вот хорошо сказано на habr'e

pipeline — водопровод. В проекте это путь идеи от момента ее высказывания, до момента когда сущность олицетворяющая идею, появляется в игре.

Новые блоги и статьи Все статьи Все блоги /
Когда логика программы не спасает от человеческих ошибок Maks 18.08.2026 В последнее время всё чаще и чаще сталкиваюсь с таким явлением, как абсолютная невнимательность (или глупость) пользователей. Проявляется это чаще всего на работе в коллективе. Допустим, человек с. . .	Лето уходит kumehtar 17.08.2026	Мысли в слух kumehtar 17.08.2026 Забавно, насколько сейчас стала доступна информация. Например о магии, духовном развитии, медитациях, и других подобных направлениях, ранее зачастую тайных, передаваемых от учителя к ученику. Хотя. . .	Перемещение строк из ТЧ в другой документ с учетом текущего пробега Maks 17.08.2026 Реализация из решения ниже выполнена на примере нетипового документа "Автозапчасти", с ТЧ "Шины". За основу взят алгоритм отсюда: https:/ / www. cyberforum. ru/ blogs/ 359708/ 10838. html Задача: . . .
Саморегулирующийся социальный контракт для сервера cross-section. Hrethgir 14.08.2026 С кодом конечно таких глубоких размышлений пока не было, впрочем я уже привык к алгоритмизации. Суть предмета записи: снова в диалоге с нейросетью (я взял пока себе ник для учётки админа - Rector). . . .	Часы электронные Uhbif79 12.08.2026 Выкладываю программу часов. Программа позволяет: 1. Использовать системное время и дату, 2. Есть возможность вводить время и дату вручную. 3. Реализованы 2 будильника: начало и конец рабочего дня. . . .	Часы с будильником на основе класса QLCDNumber Uhbif79 12.08.2026 Всем добрый день, выкладываю программу часов с будильником на основе класса QLCDNumber. Здесь я пробовал самостоятельно создавал классы, впервые столкнулся с видимостью переменной одного класса из. . .	Установка MinGW GCC 16.2 и CMake 8Observer8 10.08.2026 VK Видео: https:/ / vkvideo. ru/ video-240781534_456239017 YouTube: eY5-5PyI9NM Текстовая версия

Опции темы

Мьютексы и потоки

Решение