Могу ли я реализовать блокировку очереди, используя семафор в Java?

 путь?

я есть очередь блокировки, которая продолжает получать сообщения через какое-то приложение, теперь в приложении asp.net я пытался использовать очередь и записать вывод в файл CSV / JSON. Здесь я хочу хранить сообщения размером до 1 МБ, которые ...

java BlockingQueue не имеет блокировки заглядывать?

Очереди работы производителя / потребителя

Как заставить ThreadPoolExecutor увеличить потоки до максимума перед очередью?

Некоторое время я был разочарован поведением по умолчаниюThreadPoolExecutor который поддерживаетExecutorService пулы потоков, которые используют многие из нас. Для того, чтобы из Javadocs: Если запущено больше чем corePoolSize, но меньше чем ...

Очередь заполнена, на глубине очереди блокировки требуется уточнение

При заполнении очереди из содержимого файла глубина, кажется, никогда не увеличивается, так как элементы в этой реализации не добавляются. BlockingQueue<String> q = new SynchronousQueue<String>(); ... fstream = ...

Эквивалент канала Голанг на Яве

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

Вы можете столкнуться с проблемами, если целевая коллекция (та, к которой добавляются результаты) делает что-то «умное». Но поскольку вы обычно сливаете очередь в коллекцию, к которой имеет доступ только один поток, это скорее теоретическая проблема.

ентацияBlockingQueue [http://download.oracle.com/javase/6/docs/api/java/util/concurrent/BlockingQueue.html] говорит, что массовые операции не являются потокобезопасными, хотя в нем явно не упоминается метод driTo (). Реализации BlockingQueue ...

что не так с моей техникой контроля датчиков?

(пожалуйста, прочтите ОБНОВЛЕНИЕ 3 в конце)m разрабатывает приложение, которое постоянно работает с датчиками устройства, работает с

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

У меня есть один производитель потоков, который создает некоторые объекты задач, которые затем добавляются вArrayBlockingQueue (который имеет фиксированный размер). Я также начинаю многопоточный потребитель. Это сборка как фиксированный ...