Передача данных между потоками/процессами

Ребят, у вас тут поактивнее раздел. В соседней ветке .NET я не нашел решения, может java-программисты знают как лучше сделать.
Суть такая. Могут работать неограниченное число копий моей программы. В программе пользователь может создавать объект Разъем. Любой из объектов с одинаковым именем должен при изменении сообщить остальным во всех запущенных процессах, чтобы они также изменились.
Первоначальная реализация - Каждый объект при создании создает/открывает общий файл в памяти и запускает поток, который ждет сигнала WaitOne() в бесконечном цикле. Когда кто-то меняет состояние, он записывает данные в общий MemoryMappedFile и устанавливает сигнальное состояние. Все потоки получают сигнал, читают файл, меняют состояние объекта. По задумке, установивший сигнальное состояние поток, его и сбрасывает, когда сигнал приходит и ему в надежде, что все его уже прочитали, но увы - здесь некоторые объекты остаются в неведении.
Далее я усложнил - в файл еще стал записывать таблицу всех объектов, которые используя этот же файл, в нем прописываются при создании и оставляют пометку о прочтении, а сброс сигнала делается только в случае, если все отчитались о прочтении. При уничтожении объект исключает себя из общей таблицы. Короче такая каша тоже не есть хорошо. Так как многократные чтение/запись, да еще в разных потоках заставляют сильно болеть голову.
Может есть какие предложения как все это реализовать?

0

Кафка?

0

Сообщение от xoraxax Кафка?

Не знаю. Но мне очень хочется найти простое, изящное решение.

0

Попробуй, в описание твоё сильно не вникал, но на первый взгляд похоже

0

Что-то мне кажется, не получится прикрутить Kafka к .NET приложению. Нужно решение средствами языка.

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

0

Сообщение от rvs_dk Что-то мне кажется, не получится прикрутить Kafka к .NET приложению.

Если кажется, гуглить надо.

Добавлено через 3 минуты
Ну или альтернатива: https://johnkoerner.com/csharp... -protobuf/

0

Сообщение от rvs_dk Каждый объект при создании создает/открывает общий файл в памяти и запускает поток, который ждет сигнала WaitOne() в бесконечном цикле. Когда кто-то меняет состояние, он записывает данные в общий MemoryMappedFile и устанавливает сигнальное состояние. Все потоки получают сигнал, читают файл, меняют состояние объекта. По задумке, установивший сигнальное состояние поток, его и сбрасывает, когда сигнал приходит и ему в надежде, что все его уже прочитали, но увы - здесь некоторые объекты остаются в неведении. Далее я усложнил - в файл еще стал записывать таблицу всех объектов, которые используя этот же файл, в нем прописываются при создании и оставляют пометку о прочтении, а сброс сигнала делается только в случае, если все отчитались о прочтении. При уничтожении объект исключает себя из общей таблицы.

Сообщение от rvs_dk очень хочется найти простое, изящное решение.

Незнаю так принято у дотнетчиков изобретать велосипеды или это просто у тебя так?

Любой месседж бас спасет отца русской демократии. Многие из них кроссплатформенны и либо имеют REST API, либо клиентов под разные языки. Либо и то и другое

Тот же RabbitMQ вообще на erlang написан и его юзают где угодно.

0

korvin_, KEKCoGEN, я так то ни разу не программист. Так увлекаюсь немного. Что для вас кажется элементарным - для меня темный лес. Сам офигефаю, как в многопоточность забрался. Поэтому

Сообщение от KEKCoGEN месседж бас

Сообщение от KEKCoGEN REST API

вот честно ни о чем не говорят. И велосипед изобретаю тоже от отсутствия системных знаний.

0

Так и что мешает прочитать, что такое Кафка? Ну или хотя бы на Ютубе посмотреть

0

rvs_dk, может это поможет:
Одновременное чтение и запись в файл
Многопоточность в Java
Многопоточность в Java: ExecutorService

Вы приведите фрагменты кода, который вы пишете в упрощенном виде. Тогда будет проще вам помочь.

1

vvm28, я так то пишу на VB.NET. Сюда, так сказать больше за концепцией обратился.
Код приводил тут Вызов события в MemoryMappedFiles.
Правда я уже все усложнил. В файле организовал таблицу с подключенными потоками, в которую все отчитываются. Но сейчас проблема в том, что если мы создаем новые объекты - таблица актуальна, каждый себе присваивает корректный номер. А как только проходит изменение, идет одновременное чтение/запись из всех потоков и часть таблицы затирается.

SyncLock по ссылке на файл в памяти не помогает.

0

Вот примерная схема работы

Миниатюры

 

0

Проще наверное найти какие-то готовые аналоги или похожие решения:
Why use Memory Mapped File or MapppedByteBuffer in Java
Java Memory-Mapped Files – Java MappedByteBuffer

1

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

0

По теоретической части смотрите, ищите - "потокобезопасность в java"

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

0

vvm28, вопроснечитайответпиши. Какая джава? ТС же несколько раз сказал что он не на джава пишет.

0

vvm28, то есть запись/чтение в файл в памяти из разных потоков, которые могут быть еще и в разных процессах невозможно организовать без потерь информации?
Сейчас изменил методику - разбил на 3 файла, чтобы меньше путаться. 2 файла работают нормально. Осталось организовать отчет о выполнении в 3й файл. Тут либо просто число должно быть (каждый поток 1 раз увеличивает счетчик), либо через разделитель перечень номеров потоков с отметкой.

Сообщение от KEKCoGEN Какая джава?

Вообще изначально хотел на джаве эту прогу делать, но все таки не решился из-за сложностей для меня в визуализации. А так очень много общего. Пока изучал Джаву, много открыл для себя и в VB.NET.

0