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

@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 — водопровод. В проекте это путь идеи от момента ее высказывания, до момента когда сущность олицетворяющая идею, появляется в игре.

Новые блоги и статьи Все статьи Все блоги /
Скрипты Tampermonkey для CyberForum, ChatGPT, Claude и пр. Jin X 06.09.2026 Скрипты Tampermonkey для CyberForum, ChatGPT, Claude и пр. Работая с форумом и нейросетями в браузере часто хочется что-то подкорректировать или добавить какого-то функционала. Ниже прикреплён. . .	Программа опроса у.з. расходомера SLS-720F Argus19 02.09.2026 Программа опроса у. з. расходомера SLS-720F Программа опрашивает один раз в минуту три ультразвуковых расходомера SLS-720F через интерфейс RS-485 по протоколу Modbus RTU. Опрашиваются регистры. . .	Hyper-V: Компьютер должен поддерживать доверенный платформенный модуль 2.0. Maks 31.08.2026 При установке Windows 11 на виртуальную машину Hyper-V 2-го поколения вылезла такая ошибка: Решение: в параметрах виртуальной машины, в разделе "Безопасность" (Security) активировать флаг. . .	Архитектура биовида Стива в Майнкрафте: Зачем бонобо кубический каннибализм anaschu 30.08.2026 Кубический Вагинокапитализм в Minecraft: Математический инвариант ОДУ и рок Стивов-бонобо Главная задача разработанной «Модели Всего» — наглядно продемонстрировать наличие системной «судьбы». . .
Оттачиваю умение писать js программы. russiannick 30.08.2026 Проектом выходного дня стало написание Книги шифров Виженера. Итогом стала версия 200, синий туман. Синий туман назван так, потому что замораживает текст под собой. Нажатие синих кнопок управляют. . .	мат медиц модель 30. презентация проекта anaschu 27.08.2026 хоп хоп хоп хидахоп, а я кладую))	Как у меня протекала болезнь zorxor 27.08.2026 Здравствуйте, друзья! Эта запись блога предназначена именно для вас - для моих дорогих друзей, которые знали меня лично. Чтобы ответить на вопрос - а что же со мной произошло на самом деле? Я учился. . .	Нашел вот забавное видео о измерениях. Лучшее что я видел на эту тему kumehtar 26.08.2026 ILETXiw9bMQ Основная суть и тезисы по измерениям: 0D (Нулевое измерение): точка, не имеющая длины, ширины, высоты или объема. Объект не может перемещаться в 0D. 1D (Первое измерение):. . .

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

Решение