Как ждать в диапазоне атомарных чисел?

Question

[Павел Соколов]

Я хочу сделать аналог std::mutex, но немного с другим функционалом.
Суть заключается в том, что функтор-владелец может вызовом оператора инкрементировать и декрементировать атомарный size_t (начал исполнение - увеличил, заканчиваешь - уменьшил), а сторонние функции могли работать только когда значение (допустим) =0. Для атомарных чисел есть wait функция, которая заставляет ждать поток, пока не вызван notify. Проблема wait в том, что оно будет ждать только (допустим) при 0, а мне нужно ждать в диапазоне [1;-1]. Как такое можно реализовать?
Я пробовал делать так:

while(my_atomic_int.load() != 0) my_atomic_int.wait(my_atomic_int.load());

Но я так понимаю - оно не потокобезопасно из-за цикла и != 0.

Comments

[Wataru]

Можете задачу описать, которую вы решаете. Вот есть у вас несколько потоков. Что они должны делать? Не понятно, что вы счетчиком пытаетесь сделать. Просто начинать какую-то работу, когда счетчик ноль - не дает никаких гарантий.

[Павел Соколов]

Wataru, мне нужно, чтобы взаимодействие с членами функтора допускалось только если функтор не исполняется

[Wataru]

Павел Соколов, Без какого-то мьютекса этого не сделать. Им будет владеть или функтор, или кто-то кто хочет что-то другой.

Вообще, по описанию не понятно, почему вам не подходит просто мьютекс. Им или владеет поток с функтором, или кто-то другой, "взаимодействующий с членами функтора".

Если у вас потоков, исполняющих функтор, или "других" может быть много, но работать могут только или те или другие, то это делается с помощью трех мьютексов и пары счетчиков. что-то вроде RW lock

Если поток с функтором только один, то это в точности задача чтения-записи, когда читающих может быть много, а пишущий только один.

[Павел Соколов]

Wataru, у меня вызовов оператора функтора может быть несколькими потоками, но работа с полями только 1 и если все вызовы оператора завершились. При этом если есть взаимодействие не вызовом оператора функтора, сам оператор должен ждать, пока модификация функтора будет окончена. То есть если операторы выполняются - то они не блокируют друг-друга (ибо только читают), но они блокируют редактирование членов. Если редактирование членов началось - они ждут пока оно закончится.

Я надеюсь, что описал задачу подробнее и понятнее.

У меня была мысль с счетчиком: 0 - значит функтор не вызван (делаем -1 и работаем модифицируя/делаем +1 и работаем оператором), -1 это модификация (что блокирует операторы), [+1;-2] это число работающих операторов (вызванные потоками). Видимо она неверная.

Answer 1

[Wataru]

То, что вы описали в комментариях, это буквально блокировка чтения-записи. Функтор читает данные и может выполнятся параллельно несколько раз, но запись может быть только одна и она блокирует все чтения. Решение описано в википедии: 2 мьютекса, один счетчик. Атомиков не надо.