Результаты поиска по запросу "blockingqueue"
что не так с моей техникой контроля датчиков?
(пожалуйста, прочтите ОБНОВЛЕНИЕ 3 в конце)m разрабатывает приложение, которое постоянно работает с датчиками устройства, работает с
Эквивалент канала Голанг на Яве
У меня есть требование, где мне нужно читать из набора очередей блокировки. Очереди блокировки создаются библиотекой, которую я использую. Мой код должен чит...
Предполагается, что pthread_cond_wait () блокирует мьютекс при возврате, и это могло произойти, но окончательная разблокировка не прошла, так как мы принудительно отменили поток. В целях безопасности я обычно стараюсь вообще не использовать pthread_cancel (), поскольку некоторые платформы даже не поддерживают это. Вы можете использовать изменчивый bool или атомарный и проверить, должна ли нить быть закрыта. Таким образом, мьютексы также будут обрабатываться чисто.
я проблема с pthreads, где я думаю, что захожу в тупик. Я создал очередь блокировки, которая, как мне показалось, работала, но после некоторого тестирования я обнаружил, что если я пытаюсь отменить несколько потоков, которые блокируют блокирующую ...
путь?
я есть очередь блокировки, которая продолжает получать сообщения через какое-то приложение, теперь в приложении asp.net я пытался использовать очередь и записать вывод в файл CSV / JSON. Здесь я хочу хранить сообщения размером до 1 МБ, которые ...
Вы можете столкнуться с проблемами, если целевая коллекция (та, к которой добавляются результаты) делает что-то «умное». Но поскольку вы обычно сливаете очередь в коллекцию, к которой имеет доступ только один поток, это скорее теоретическая проблема.
ентацияBlockingQueue [http://download.oracle.com/javase/6/docs/api/java/util/concurrent/BlockingQueue.html] говорит, что массовые операции не являются потокобезопасными, хотя в нем явно не упоминается метод driTo (). Реализации BlockingQueue ...
Блокировка очереди и многопоточного потребителя, как узнать, когда остановиться
У меня есть один производитель потоков, который создает некоторые объекты задач, которые затем добавляются вArrayBlockingQueue (который имеет фиксированный размер). Я также начинаю многопоточный потребитель. Это сборка как фиксированный ...
Очередь заполнена, на глубине очереди блокировки требуется уточнение
При заполнении очереди из содержимого файла глубина, кажется, никогда не увеличивается, так как элементы в этой реализации не добавляются. BlockingQueue<String> q = new SynchronousQueue<String>(); ... fstream = ...
Страница 1 из 2