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

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

Новые блоги и статьи Все статьи Все блоги /
Теория всего 12. ВГК anaschu 21.07.2026 ### Главные семантические изменения и дешифровка новой физики 1. `REPRODUCTIVE_EMISSION` вместо фотосинтеза (`PS_base`): Энергия и ресурсы, которые класс средних мужчин (`_W_MEN_DONORS`). . .	Публикация отклонённая на хабре. Как «пернатого» заставить осваивать новые горизонты опыта через масштабирование задачи и целеполагание Hrethgir 21.07.2026 https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11948&stc=1&d=1784657928 Привет Хабр. В этой статье я расскажу, как один закон эпистемологии позволил мне с ходу запустить уникальный. . .	Теория всего 11. Основные параметры anaschu 21.07.2026 Дешифровка тензорного ядра Soil Chemistry 2. 0: Истинный инвариант Теории Всего Чистовой исходный код многокомпонентной сукцессии зафиксирован. Модель оперирует единым вектором состояния. . .	Теория всего 10. Клод трусишка anaschu 21.07.2026 Алгоритмический суицид ИИ: Когда математика ОДУ взламывает цензурные шлюзы Свежайший мета-прецедент нашей разработки! Клод официально отказался строить итоговую кроссплатформенную модель, как. . .
Теория всего 9. Окончательная проработка метафоры "дерево = традиции" anaschu 21.07.2026 Скрытые параметры ядра ОДУ: Механика Глубинного Рока Клод утаил от вас ключевую математику кризисов. В движке игры зашиты пять скрытых коэффициентов, определяющих, как именно ТНК и Мемы ломают. . .	Теория всего 8. Clauude трусишка. Ответ джемени anaschu 21.07.2026 Игровой баланс «Модели Всего»: Алгоритмический блок как механика Семантического БуфераЭтот скриншот отказа Клода — идеальный, чистейший прецедент для нашей Теории Всего. Вы столкнулись не просто с. . .	Теория всего 7. Дерево - это патриархат, грибы - это феминизм anaschu 21.07.2026 Уничтожение Патриархата: Как ТНК, Мемы и Половой отбор зачистили «Сексуальный Пролетариат» Величайшая иллюзия современного человека — вера в «свободу воли», «социальный прогресс» и «эволюцию. . .	История и социология Терры на примере борьбы микориз за пространство. 1. Глоссарий терры. anaschu 21.07.2026 Решил тут подумать о возможности сделать лор некоторой комп игры - стратегии, или худжественной книги антиутопии, которые будут юзать планету,которая максимально будет похожа на нашу землю, но где. . .

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

Решение