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

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

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

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

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

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

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

У меня есть очередь блокировки объектов. Я хочу написать поток, который блокирует, пока в очереди нет объекта. Аналогично функциональности, предоставляемой BlockingQueue.take (). Однако, поскольку я не знаю, смогу ли я успешно обработать ...

Предполагается, что pthread_cond_wait () блокирует мьютекс при возврате, и это могло произойти, но окончательная разблокировка не прошла, так как мы принудительно отменили поток. В целях безопасности я обычно стараюсь вообще не использовать pthread_cancel (), поскольку некоторые платформы даже не поддерживают это. Вы можете использовать изменчивый bool или атомарный и проверить, должна ли нить быть закрыта. Таким образом, мьютексы также будут обрабатываться чисто.

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

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

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

 путь?

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

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

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

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