11 голосов
Принятый

Для чего нужны мьютексы в C++

Ну вот, представьте ситуацию - вы с женой одновременно кладете на свой семейный счет деньги. Примерно так: int sum = howManyMoney(); sum += 10000; MoneyToAccount(sum); И то же одновременно делает ...
Harry's user avatar
  • 222k
11 голосов
Принятый

Как mutex определяет, какой именно объект нужно блокировать?

Дополню ответ @alexis031182. Мьютекс или семафор, как его обобщение (конкретно, объект (переменная), расположенный по некоторому адресу) это точка синхронизации потоков кода одного или (в некоторых ...
avp's user avatar
  • 46.1k
10 голосов

Как mutex определяет, какой именно объект нужно блокировать?

У любого мютекса есть функции lock и unlock (они могут называться по разному, но суть от этого не меняется. Некоторые мютексы могут использовать raii, автоматически вызывая нужные функции). А ...
KoVadim's user avatar
  • 112k
9 голосов

Как mutex определяет, какой именно объект нужно блокировать?

По сути, никак. Он и не защищает конкретный объект. Мьютекс лишь гарантирует, что обращения к данным под мьютексом сериализованы. (То есть, что невозможны гонки данных.) Ответственность работать с ...
VladD's user avatar
  • 207k
7 голосов
Принятый

Реализация Mutex без API операционной системы

Во-первых, с чего вы взяли что вызова Lock и Unlock одновременно произойти не может? Может, как и два Lock одновременно. Главная проблема - два потока могут одновременно проверить переменную lock, до ...
Pavel Mayorov's user avatar
7 голосов

Как mutex определяет, какой именно объект нужно блокировать?

Мьютекс по сути обеспечивает то, что называется «критической секцией» (критическим разделом) - т.е. код, который может выполняться одновременно только одним потоком. Но если данный мьютекс навесить ...
Harry's user avatar
  • 222k
6 голосов
Принятый

Потоки. Ожидание выполнения потоков с++

Ожидание выполнения потока делается через join. Мьютекс для этой задачи не нужен. Как и лишние два потока. thread func_thread1(anyFunc1); anyFunc2(); func_thread1.join(); anyFunc3();
Pavel Mayorov's user avatar
6 голосов
Принятый

Как наиболее корректно реализовать mutex со счетчиком?

В стандартной библиотеке готового семафора нет, по этому его надо писать самому, делая ожидание на condition_variable. В простейшем варианте это class Semaphore { public: explicit Semaphore(int ...
Abyx's user avatar
  • 31.2k
6 голосов

Как устроен мьютекс?

Поток может перейти в ждущее состояние, и спать, пока его не разбудит другой поток. Так ничего "греться" не будет. К сожалению, такой переход в другое состояние сам по себе относительно ...
Alex Guteniev's user avatar
6 голосов
Принятый

зачем условной переменной нужен мьютекс

Типовое использование условной переменной без плюсового сахара обычно выглядит как-то так (псевдокод)¹: condition_variable cv; // условная переменная mutex dataMutex; // Мьютекс, контролирующий ...
Fat-Zer's user avatar
  • 23.2k
4 голоса
Принятый

Rust. Вызов метода у Arc<T>

Дело в механизме Deref coercions или "Преобразования при разыменовании". Arc реализует типаж Deref, значения &Arc<T> будут автоматически преобразованы в &T, когда это необходимо. Метод ...
Zaur Bogus's user avatar
4 голоса

Реализация Mutex без API операционной системы

Ваша реализация похожа на spinlock, а не mutex. Тем не менее, чтобы сделать её корректной(хоть и малоэффективной) нужно изменить тип lock c bool на std::atomic_bool и немного поменять цикл: bool ...
ixSci's user avatar
  • 23.8k
4 голоса

Реализация Mutex без API операционной системы

На некоторых архитектрурах присваивание может происходить не атомарно (попробуйте на восьмибитной AVR записать 4 байта одной инструкцией - фиг вам). Одно ядро процессора может совершенно не ведать, ...
gbg's user avatar
  • 22.3k
4 голоса
Принятый

Предотвращение одновременного запуска нескольких AsyncTask

У AsyncTask есть метод executeOnExecutor (Executor exec, Params... params), с помощью которого можно организовать поведение Ваших тасков. Так же есть два заготовленных для этого Executor'а: ...
woesss's user avatar
  • 12.2k
4 голоса
Принятый

Mutex работает некорректно между процессами

Если вы в, например, WPF приложении в OnStartup создаете просто локальную переменную мьютекса, то после того, как метод будет выполнен, переменная и сам мьютекс будут уничтожены сборщиком. Чтобы ...
tym32167's user avatar
  • 33k
4 голоса
Принятый

буфер ostream защищен мьютексом?

Стандарт ([iostreams.threadsafety]) говорит нам: Concurrent access to a stream object, stream buffer object, or C Library stream by multiple threads may result in a data race unless otherwise ...
Fat-Zer's user avatar
  • 23.2k
4 голоса
Принятый

Порядок операций между вызовами lock unlock

TL;DR: Может переставить, если у него получится доказать, что этого никто не заметит. Компилятор вправе менять по своему произволу операции, их порядок, выбрасывать любые операции и вводить новые, ...
VladD's user avatar
  • 207k
3 голоса
Принятый

Атомарные операции

Мне кажется, что проблема в использовании функции store - она же просто записывает литерал 1 каждый раз. Если переписать с использованием fetch_add: extern crate rayon; use std::sync::atomic::{...
ozkriff's user avatar
  • 605
3 голоса
Принятый

Программа работает правильно с 2-3 попытки (потоки). - C#

Это происходит потому, что потоки созданы для того, чтобы работать параллельно. Операции в потоках не обязаны выполняться по одной из каждого по очереди. В данном случае первый поток в нескольких ...
Nikolay Lebedev's user avatar
3 голоса
Принятый

Использование std::shared_mutex и проблема "обделения" писателя

Не знаю, как с приоритетами, а идея двух входов довольно очевидна. Все делают эксклюзивный lock на E1. Получив его, читатели делают shared lock на E2, а писатели эксклюзивный. Получив lock на E2 и ...
avp's user avatar
  • 46.1k
3 голоса
Принятый

Многопоточная работа со связанным списком

Взгляните на вот этот цикл внимательнее: ListItem item; while (true) { pthread_mutex_lock(&mutex); list.insertHead(&item); pthread_mutex_unlock(&mutex); } Здесь вы добавляете ...
Pavel Mayorov's user avatar
3 голоса
Принятый

C++ реализация call_once

Стандарт не налагает ограничений на реализацию std::call_once поэтому, его реализация может быть как с блокировками, так и без(я не знаю, возможно ли такую реализацию придумать). Что касается Вашей ...
ixSci's user avatar
  • 23.8k
3 голоса
Принятый

TryOpenExisting() и использование Discards (пустых переменных) на обьектах которые наследуют IDisposable

Сама документация описывает что "пустые переменные" просто ссылаются на некую "пустую" область памяти. То есть не занимают места. Что вряд ли означает что они будут вызывать Dispose() у IDisposable ...
Andrew Stop_RU_war_in_UA's user avatar
3 голоса
Принятый

Не удаляется мутекс

CreateMutex "открывает" свежесозданный mutex. OpenMutex тоже "открывает" существующий mutex. Если вы хотите, чтобы mutex был уничтожен, вам надо "закрыть" через CloseHandle все "открытия". То есть ...
AnT stands with Russia's user avatar
3 голоса

Как синхронизировать доступ к двум объектам из разных потоков, если последовательность доступа может быть разной в разных потоках?

В данном случае можно добиться строго одинаковой последовательности доступа путем сравнения указателей на объекты для определения порядка: void transfer(Account& from, Account& to, double ...
user7860670's user avatar
  • 29.9k
3 голоса
Принятый

Golang использования sync.Mutex

Читайте внимательно документацию: (…) The Client's Transport typically has internal state (cached TCP connections), so Clients should be reused instead of created as needed. Clients are safe for ...
Ainar-G's user avatar
  • 16k
2 голоса
Принятый

Простое многопоточное приложение с использованием мьютекса

Функция WaitForSingleObject ожидает освобождения мютекса и занимает его сама.
Smithson's user avatar
  • 847
2 голоса

write|read mutex

Если boost не подходит, тогда остаётся использовать ОС-зависимые решения. Т.к. Вы используете MSVC, тогда Вам должен подойти SRW lock. Если же нужна кроссплатформенность, тогда можно ОС-зависимые ...
ixSci's user avatar
  • 23.8k

Допускаются только превышающие минимальную длину ответы с наивысшим рейтингом, не являющиеся общими