народ подскажите каким путём пойти для организации потокобезопасных классов, что использовать task c++11, OpenMP, Microsoft PPL, или ещё что порыть

Если задача легко решается тем, что есть в стандартной либе, то, естественно, лучше использовать ее. Только не используйте std::async, с остальным проблем там нет.

async я читал что много на неё ругаются но не копал особо бо ней, так что не предовал ей внимание

Если задача легко решается тем, что есть в стандартной либе, то, естественно, лучше использовать ее. Только не используйте std::async, с остальным проблем там нет.

А что с асинк?

А что с асинк?

Если вам раз в минуту или реже надо что-то сделать асинхронно, то ничего особо страшного нет. В остальных случаях лучше написать свой\взять готовый планировщик\очередь с пулом, т.к. для std::async не указан способ выбора потока для исполнения и, например, в винде это, вроде, пул потоков по количеству потоков процессора, а в линуксе это просто новый поток на каждый вызов. И для запуска всего 2 политики, а политика по-умолчанию не указана.

думаю каким путём пойти... использовать систему сообщений между классами или писать что либо другое

Найдите среди открытых проектов что-нибудь похожее на вашу задачу и посмотрите, как там реализовано.

Если классы дожны знать какой-то общий POD статус, то можно std::atomic использовать, если должны ждать статус, то добавить std::condition_variable.

народ подскажите каким путём пойти для организации потокобезопасных классов, что использовать task c++11, OpenMP, Microsoft PPL, или ещё что порыть

Я не знаю конечно что надо, но да, тоже двачую за атомики - для обмена инфой самое оно в примитивном случае... Можно подробнее про контекст? От него все зависит...

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

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

Многопоточный 3д движек

сам юнити написан на плюсах а шарпы всеголоишь образуют обёртку над функционалом плюсов

фреймворк ))

Наверное все общение между потоков нивелирует все хорошее что можно получить

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

Я не знаю что там сделано, ибо никогда не заглядывал и не работал

Я все ещё не понял задачу решаемую

Классы просто должны быть потокобезопасны?

Или их инстансы будут меняться инфой?

если знаете то в юнити цикл обработки gameObject'ов проходит по его компонентам и вот тут т.к. GO по сути являются независимыми объектами можно организовать паралельность обработки.(за исключением если есть чёткая цепочка выполнения GO)

В первом случае - обложить барьерами на запись/чтение

если знаете то в юнити цикл обработки gameObject'ов проходит по его компонентам и вот тут т.к. GO по сути являются независимыми объектами можно организовать паралельность обработки.(за исключением если есть чёткая цепочка выполнения GO)

Ну тогда тредсейф очередь и хранить в ней go

Самый быстрый вариант

т.е выполняем строго описанный цикл обработки GO 1,2... n. А остальные GO по сути можно выполнить хаотично( но тут проблемы в пользовании общими ресурсами)

либо организовать некий пул с орзанизацией доступа по сообщениями либо хз

Некий пул либо хз :)

пока варианты перебираю, решил спросить есть ли варианты у вас

Если я правильно понял, то необходимо параллельно обрабатывать игровые объекты. Т.к. один объект сразу в 2х потоках обрабатывать скорее всего нельзя, то создать просто пул, куда кидать задачу и объект.

Если есть куча объектов и их надо обработать - то map парадигма - то что надо

Если я правильно понял, то необходимо параллельно обрабатывать игровые объекты. Т.к. один объект сразу в 2х потоках обрабатывать скорее всего нельзя, то создать просто пул, куда кидать задачу и объект.

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

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

Один объект из разных потоков - так се кмк

На локи все время уйдёт

А если оно ещё и в кэш не влезет

Или не дай бог влезет

Хз чо страшнее

сама по себе заадача интересная, может я сильно копнул ))

Один объект из разных потоков - так се кмк

Ага, но я встречал подобное где-то. Там вокруг геттеров были локи.

сама по себе заадача интересная, может я сильно копнул ))

Ну если бы ещё представлять цель... Обобщим... если есть куча объектов и их надо параллельно обработать - пул потоков и тредсейф контейнер с объектами. Потоки попают объекты и делают работу

[In reply to Mike Gamaev] Ну если бы ещё представлять цель... Что именно объяснить?

Вообще в играх стараются обрабатывать однотипные объекты одной пачкой в одном потоке, чтобы и параллельно и от кэша выигрыш получить. Т.е. делают планировщик, куда кидают вектор объектов и их обработчик с приоритетом.

Вообще в играх стараются обрабатывать однотипные объекты одной пачкой в одном потоке, чтобы и параллельно и от кэша выигрыш получить. Т.е. делают планировщик, куда кидают вектор объектов и их обработчик с приоритетом.

Да, к этому хотел подвести, есть один контейнер с bulk записью и чтением

Всегда за него тут топлю

Да, к этому хотел подвести, есть один контейнер с bulk записью и чтением

И он ещё и локфри

Всегда за него тут топлю

https://github.com/cameron314/concurrentqueue

я завис.. )) пытаюсь понять о чём речь

я завис.. )) пытаюсь понять о чём речь

Для скорости - обработчик должен забирать данные пачками. В вашем случае, если GO хранятся в каком то контейнере - то надо забирать сразу несколько объектов на обработку

я смотрю то что скинул в Гите

А, локфри очередь

Для межпоточного обмена

Создал инстанс, напихал туда объектов и запустил потоки... все просто

Создал инстанс, напихал туда объектов и запустил потоки... все просто

И оно Supports super-fast bulk operations

я завис.. )) пытаюсь понять о чём речь

Группируйте одинаковые объекты и обрабатывайте их вместе. Т.е. у вас есть пачка объектов A, к которым надо с заданными интервалами применять метод B. Храните в векторе или деке (условно) все объекты типа А и отдавайте их в планировщик. Можно и планировщик умный написать, который будет не просто всю пачку в одном потоке копать, но, в зависимости от необработанного размера пачки и количества свободных потоков, подключать еще один поток на обработку пачки, пока не придет что-нибудь с более высоким приоритетом. Тут все вашей фантазией ограничивается на самом деле.

нужно поруть данные на гите чтобы понять

пытаюсь понять как этим пользоваться

что происходит под копотом

if (argv[1][i] - !!a != a[i]) Что значат два восклицательных знака?

операция перед (!a != a[i])

if (argv[1][i] - !!a != a[i]) Что значат два восклицательных знака?

приведение к bool

Не понятно все равно. Есть массив a[], который содержит строку. Что проверяет это условие?

приведение к bool

хитротааа

Не понятно все равно. Есть массив a[], который содержит строку. Что проверяет это условие?

если массив а расположен не по нулевому адресу, то проверяет не равен ли i-ый элемент из аргументов командной строки минус один i-ому элементу массива а

если по нулевому, то без минус один

Спасибо большое

да не за что, если скинешь больше кода, могу предположить, зачем такой хак

ERROR: S client not available

Я в личку скину позже, не против?

ок

Ребят, вопрос такой возинк. Как обычно поступают компиляторы в ситуации, когда конструкторы копирования попадают в подмножество конструкторов-шаблонов? Пример: template<typename T> class A { public: template<template U> A(const A<U> &a); template<template U> A(A<U> &&a); }

если массив а расположен не по нулевому адресу, то проверяет не равен ли i-ый элемент из аргументов командной строки минус один i-ому элементу массива а

кривовато сказал, ну думаю ты понял, что если переменной а не присвоили NULL

Ребят, вопрос такой возинк. Как обычно поступают компиляторы в ситуации, когда конструкторы копирования попадают в подмножество конструкторов-шаблонов? Пример: template<typename T> class A { public: template<template U> A(const A<U> &a); template<template U> A(A<U> &&a); }

12.8.2 A non-template constructor for class X is a copy constructor if its first parameter is of type X&, const X&, volatile X& or const volatile X&, and either there are no other parameters or else all other parameters have default arguments (8.3.6)

в твоем случае, компилятор сгенерирует конструктор копирования самостоятельно, как если бы ты объявил A(const A& ) = default;

в твоем случае, компилятор сгенерирует конструктор копирования самостоятельно, как если бы ты объявил A(const A& ) = default;

Спасибо.

т.е выполняем строго описанный цикл обработки GO 1,2... n. А остальные GO по сути можно выполнить хаотично( но тут проблемы в пользовании общими ресурсами)

почитай как банжи организовали очередь game loop в дестини, у них есть презентахи на эту тему

а ссылку можно?

И по поводу этого вкраце может ктонибудь объяснить его принцип работы https://github.com/cameron314/concurrentqueue/blob/master/concurrentqueue.h

почитай как банжи организовали очередь game loop в дестини, у них есть презентахи на эту тему

а ссылку можно?

И по поводу этого вкраце может ктонибудь объяснить его принцип работы https://github.com/cameron314/concurrentqueue/blob/master/concurrentqueue.h

там же есть ссылка http://moodycamel.com/blog/2014/detailed-design-of-a-lock-free-queue

ты читал?

И по поводу этого вкраце может ктонибудь объяснить его принцип работы https://github.com/cameron314/concurrentqueue/blob/master/concurrentqueue.h

Локфри структуры делаюься через атомарную операцию compare and swap

и наверное это должен был быть первый вопрос - ты понимаешь, что такое compare-and-swap (cmpxchg) и вот это все?

и наверное это должен был быть первый вопрос - ты понимаешь, что такое compare-and-swap (cmpxchg) и вот это все?

вот мне интересно, как долго может прождать пишущий в очередь с cas с допустим 50 пишущими

вот мне интересно, как долго может прождать пишущий в очередь с cas с допустим 50 пишущими

достаточно долго, чтобы не строить риал-тайм системы на этом)

50 пишущих это повод разбить запись на несколько буферов

Наверн в худшем случае от количества пишущих зависит

с меньшим количеством конкурирующих за запись и конкуренцией буферов за флаш в очередь

от всего зависит, в том числе от удачи-неудачи. тут нет детерминизма

неудача это когда первым должен писать, а в итоге последним это делаешь :[

неудача это когда система строится на предположении о том, что кто-то первым должен писать

ты читал?

не особо понятно

и наверное это должен был быть первый вопрос - ты понимаешь, что такое compare-and-swap (cmpxchg) и вот это все?

Ты об этой атомарной процессорной команде? https://ru.wikipedia.org/wiki/Сравнение_с_обменом

да

ну конечно знаю и

не особо понятно

Там же есть описание идеи и методов. Берите и пользуйтесь.

с переводчиком не особо понятно

нашёл вот это https://habrahabr.ru/post/245837/

я не знаю неужели только у меня такая понацея пользоваться только теми вещями которые понимаю...