How to become an author
Search
Write a publication
Pull to refresh

Comments 40

Что-то не улавливаю. Поясните, плс?
This comment wasn’t rated yet0

Во-первых, у компилятора могут оказаться основания полагать, что поле _status в цикле не меняется, из-за чего цикл превратится в вечный. Кстати, бесконечный цикл — тоже UB, что разрешает компилятору корёжить программу дальше.


Во-вторых, значение status::up может "застрять" в кеше процессора, из-за чего цикл сделает кучу холостых операций.


Если один поток записал в переменную некоторое значение — это ещё не означает, что другой поток именно это значение и прочитает.

Total votes 4: ↑2 and ↓20
Во-вторых, значение status::up может «застрять» в кеше процессора, из-за чего цикл сделает кучу холостых операций.


Это, кстати, распространённый миф, кэши процессора когерентны и если вы в одну кэш линию что-то записали, то она «разъедется» на все ядра.
Другое дело что никто не гарантирует что запись будет осуществлена в том месте где вы написали (процессор/компилятор вольны переставлять инструкции) или вообще осуществлена — никто же не сказал что это атомик, можно вообще запись в кэш/память выкинуть или на регистрах оставить.
Total votes 3: ↑3 and ↓0+3
Другое дело что никто не гарантирует что запись будет осуществлена в том месте где вы написали

Соббсно это и будет наблюдаться как эффект "застревания" в кэше. Инструкции, меняющие переменную могут выполнится хз когда, и все это время цикл в другом потоке будет в холостую гонять.

Total votes 1: ↑1 and ↓0+1
Нельзя менять/читать значение неатомарной переменной из разных потоков. Если компилятор сможет доказать что в этом потоке переменная не меняется, он может выкинуть проверку нафиг или считать значение из памяти один раз, заменив проверку в цикле на if перед бесконечным циклом.
Total votes 4: ↑3 and ↓1+2
да хватит, хватит уже, первого комента достаточно.
Я уже так привык, что race condition всегда называют своим термином, что и думать забыл о нём, как об UB.
Total votes 2: ↑0 and ↓2-2

Ну, для такого и придумали volatile. Что впрочем не отменяет необходимость синхронизации чтения/записи

Total votes 2: ↑1 and ↓10

Так-то volatile != atomic. Но да, вы правы, использовался он чаще именно для этого

Total votes 1: ↑1 and ↓0+1
Ну нет же, не для этого придумали volatile. И даже deprecated ему собираются прикрутить в таких сценариях.
Total votes 2: ↑2 and ↓0+2
Вроде только в C++, в нормальном языке вроде оставляют, нет?
This comment wasn’t rated yet0
Хз что там в «нормальном» языке, но использование volatile для многопоточки — вещь, за которую надо увольнять. Да, volatile защищает от оптимизаций компилятора, но он не делает UB код меньшим UB, просто заметает баги под ковер. Ровно до тех пор пока вы не запустите свой «офигенный» «быстрый» алгоритм на volatile и reinterpret_cast'ах на каком-нибудь ARM.
К сожалению, x86 и друзья являются «strong ordered» архитектурами и поймать instruction reorder там сложно (вот хорошая статья, демонстрирующая, как его всё-таки словить), а значит ваш супер-мега «локфри» на волатайлах будет успешно «работать», возможно в продакшне и не один год.
This comment wasn’t rated yet0
Вы такой категоричный! Не поверите, мой код работает как раз на «каких-то» ARM'ах, и volatile там вполне достаточно. На более продвинутых процессорах — там да, нужны барьеры памяти, даже в MMIO регистр записать. Но на тех платформах, работа с которыми заполняет мои дни — нет. Поэтому я использую «нормальный язык», в котором reintrpret_cast — имя переменной. И из него работающий инструмент не выбрасывают.
This comment wasn’t rated yet0
Вы же сейчас о ключевом слове volatile, который вешают на переменную, а не о штуках типа asm volatile("" ::: «memory»);?
Если да, то у меня для вас плохие новости — либо у вас где-то есть барьер, который маскирует проблему, либо вы просто ещё не нашли багу.
Ключевое слово volatile не спасает от проблем многопоточности на relaxed-ordered архитектурах, потому что инструкции может переставлять процессор, а не компилятор (точнее, это могут делать оба, но volatile запрещает только второму).
Другое дело, что стандарт «нормального языка» ничего не говорит о многопоточности и memory ordering (поправьте, если ошибаюсь), а значит оставляет вас и компилятор в серой зоне — компилятор может вам помочь и напихать барьеров памяти, видя volatile, а может и не помогать и тогда ваш код будет содержать трудноотлаживаемую багу.
Total votes 1: ↑1 and ↓0+1
Я дико рекомендую вот этот цикл статей на Хабре, развеивает кучу мифов и даёт представление о том куда и на что смотреть, если поймали data race habr.com/ru/post/195770.
This comment wasn’t rated yet0

Так это же хорошо! Багу, не пойманную никем в первые недели/месяцы, можно считать несуществующей и пренебречь ей в принципе. Кто вам сказал, что такому коду/проекту когда-нибудь в принципе понадобится запуск на иной архитектуре?

Total votes 1: ↑0 and ↓1-1

Для многопоточности этот принцип не работает. Баги, возникающие из-за гонок, "ловить" слишком тяжело, их нужно не допускать.

This comment wasn’t rated yet0

Почему в многопоточном сервере я не вижу ни одного мьютекса или другого примитива синхронизации?


Зато я сходу вижу гонку между TcpServer::stop и TcpServer::handlingLoop...

Total votes 10: ↑10 and ↓0+10
Если отвечать на вопрос в общем (не относительно кода автора поста), то это не всегда нужно, например при параллельной обработке запросов может быть что просто ничего не надо синхронизировать.
This comment wasn’t rated yet0
Почему в многопоточном сервере я не вижу ни одного мьютекса или другого примитива синхронизации?


Блокировки вообще не обязательны для многопоточного приложения. Достаточно CAS и других атомарных операций.
Total votes 1: ↑1 and ↓0+1

Но CAS и других атомарных операций я тоже не вижу...

Total votes 2: ↑2 and ↓0+2
Как-то раз встала задача по написанию простого и быстрого многопоточного TCP/IP сервера на C++ и при этом, чтобы работал из под Windows и Linux без требования как-либо изменять код за пределами класса самого сервера.

Можно нескромный вопрос: "встала задача" по учебе (в качестве лабораторной или курсовой) или же по работе?

Total votes 5: ↑5 and ↓0+5
bool TcpServer::Client::sendData(const char* buffer, const size_t size) const {
if(send(socket, buffer, size, 0) < 0) return false;
return true;
}


А если send вернет больше 0 или 0?
Total votes 2: ↑1 and ↓10
А если при этом send послал меньше чем просили?
Total votes 2: ↑2 and ↓0+2
Да. Но это ведь ошибка, вы не послали все данные в сеть и вернули, что «всё хорошо».
Total votes 3: ↑3 and ↓0+3
К сожалению, в современном мире такие сервера уже почти никому не нужны по причине отсутствия шифрования данных.
Total votes 7: ↑1 and ↓6-5

это далеко не самая боььшая проблема, плюс есть много мест, где шифрование делается на уровнях выше

Total votes 4: ↑4 and ↓0+4
for(std::list<std::thread::id>::iterator id_it = client_handling_end.begin (); !client_handling_end.empty(); id_it = client_handling_end.begin())
for(std::list<std::thread>::iterator thr_it = client_handler_threads.begin (); thr_it != client_handler_threads.end (); ++thr_it)
if(thr_it->get_id () == *id_it) {…

Может лучше map юзать? Квадратичная сложность — так себе идея
Total votes 1: ↑1 and ↓0+1

Там на самом деле надо в список client_handling_end сразу поток класть, а не его id. И из client_handler_threads поток исключать сразу же, а не в конце.

Total votes 1: ↑1 and ↓0+1
Каждый такое писал, но не каждый рискнул выложить.
Total votes 23: ↑23 and ↓0+23
Согласен, но замечу, что самое интересное начинается, кода это действительно становится рабочим проектом, и ты начинаешь смотреть в сторону pool, epool, WSAPool, разбираешься с реактором и проактором… И для следующего проекта берешь либо boost либо poco :-)
This comment wasn’t rated yet0
есть же libuv, где при желании можно запустить N лупов по количеству ядер и получить многопоточный сервер вместо асинхронного event-based.
Total votes 1: ↑1 and ↓0+1

100-пудово. Больше 10 лет тому назад в качестве домашнего задания при собеседовании получил подобное задание. К тому времени во всю использовал уже boost.asio.
Начал делать, думал за пару вечеров управиться. Но писать плохо не хотелось. Гляжу, сроки задания едут, а выходит что-то типа упрощенного asio. А тут и другой работодатель меня и нашел :)

This comment wasn’t rated yet0
while (size == 0) size = client.loadData();

->
while (!(size == client.loadData()));

А ещё, как я непрофессионально вижу, можно платформенные дефайны поставить в один конструктор, чтобы в целом меньше кода было
Total votes 2: ↑1 and ↓10

Небольшая поправочка:


while(!(size = client.loadData()));

Требуется запомнить размер буфера в size, иначе можно было и вовсе написать:


while(!client.loadData());
This comment wasn’t rated yet0
while (!(size == client.loadData()));

Зачем несколько действий совмещать в одну строчку,
"job security"?

Total votes 1: ↑1 and ↓0+1
Sign up to leave a comment.

Articles

Show the best of all time

Your account

Sections

Information

Services

Support
© 2006–2024, Habr