0
ответов
Что или кто должен прервать поток?
Согласно Гетцу в его книге JCIP :, поскольку каждый поток имеет свою собственную политику прерывания, вы не должны прерывать поток, если не знаете, что означает прерывание для этого потока. Почему же...
вопрос задан: 13 July 2012 11:03
0
ответов
Почему не удается запустить ()Runnable, выбрасывая проверенные исключения?
Согласно разделу 6.3.2 JCIP :Runnable является достаточно ограничивающей абстракцией; run не может возвращать значение или выдавать проверенное исключение. run ()не может вернуть значение, так как его возвращаемый тип недействителен...
вопрос задан: 10 July 2012 09:16
0
ответов
Какой метод представляет задачу в среду Executor в приведенном ниже коде?
Пожалуйста, обратитесь к следующему коду из класса Javadoc of Future: FutureTask future = new FutureTask (new Callable () {public String call () {...
вопрос задан: 10 July 2012 07:52
0
ответов
@GuardedBy, @ThreadSafe, @NotThreadSafe
Я вижу, что приведенные выше аннотации широко используются в книге JCIP. Я думаю, что это действительно полезно, потому что даже при отсутствии надлежащей документации в нем кое-что говорится о синхронизации...
вопрос задан: 6 July 2012 12:34
0
ответов
Буферизация данных в многопоточном java-приложении
У меня есть многопоточное приложение, которое имеет один производственный поток и несколько потребительских потоков.
Данные хранятся в общей потоковой безопасной коллекции и сбрасываются в базу данных, когда есть достаточно ...
вопрос задан: 7 June 2012 10:01
0
ответов
Как «отменить» CountDownLatch?
У меня есть несколько потребительских потоков, ожидающих CountDownLatch размера 1 с помощью await (). У меня есть единственный поток производителя, который вызывает countDown ()после успешного завершения. Это отлично работает, когда...
вопрос задан: 4 May 2012 18:19
0
ответов
ExecutorService awaitTermination застревает
Я создал пул потоков фиксированного размера с помощью Executors.newFixedThreadPool (2) и выполнил 10 запускаемых объектов. Я установил точки останова и проследил выполнение. Однако fixedSizeThreadPool ....
вопрос задан: 13 April 2012 02:03
0
ответов
Можно ли прервать BufferedReader.readLine() с помощью Future.cancel(true)?
Допустим, я запустил поток, и у меня есть что-то вроде этого: ...//инициировать все подключения к сокету future = executor.submit ( new Runnable() { public void run() { ... ...
вопрос задан: 2 April 2012 15:55
0
ответов
java повторно использовать исполнителя
Я работаю над системой моделирования, где на каждом временном шаге мне приходится моделировать множество моделей. Я использовал FixedThreadPool для ускорения вычислений: ExecutorService executor = Executors.newFixedThreadPool (...
вопрос задан: 27 January 2012 16:09
0
ответов
ConcurrentLinkedQueue с wait () и notify ()
Я не в порядке -проработан в многопоточности.Я пытаюсь несколько раз сделать снимок экрана одним потоком-производителем, который добавляет объект BufferedImage в ConcurrentLinkedQueue, и поток-потребитель будет опрашивать ...
вопрос задан: 11 January 2012 19:56
0
ответов
Странный код в java.util.concurrent.LinkedBlockingQueue
Все! Я нашел странный код в LinkedBlockingQueue: private E dequeue () {// assert takeLock.isHeldByCurrentThread (); Узел h = голова; Узел first = h.next; ...
вопрос задан: 11 January 2012 13:13
0
ответов
Что делает ReentrantLock # tryLock (long, TimeUnit), когда пытается получить блокировку?
Что такое ReentrantLock # tryLock (long , TimeUnit) при попытке получить блокировку? Предположим, что поток A фактически владеет блокировкой myLock, а поток B вызывает myLock.tryLock (10, SECONDS), это ...
вопрос задан: 6 December 2011 10:44
0
ответов
Является ли java.util.concurrent.Future потокобезопасным?
Я пытаюсь найти документацию, указывающую, является/не является ли java.util.concurrent.Future потокобезопасным. Например, могу ли я безопасно передать один и тот же экземпляр Future нескольким потокам, которые все будут вызывать Future.get(.....).
вопрос задан: 5 December 2011 18:50
0
ответов
Как блокировать и ждать с помощью AtomicBoolean
Я ищу способ приостановить поток. Я начал с аффективного использования логического флага (называемого «приостановлено») и заключил проверку в цикл while (пауза). Внутри цикла while есть поток ....
вопрос задан: 21 November 2011 17:17
0
ответов
Разница между Executor и ExecutorCompletionservice в java
Как видно из названия вопроса, в чем разница между Executors и ExecutorCompletionService классами в java ? Я новичок в Threading, поэтому, если кто-нибудь может объяснить с помощью фрагмента кода, ...
вопрос задан: 13 October 2011 17:30
0
ответов
Планирование Callable по фиксированной ставке
У меня есть задача, которую я хочу работать с фиксированной скоростью. Однако мне также нужен результат задачи после каждого исполнения. Вот то, что я пробовал: планированию класса задач реализует Callable ...
вопрос задан: 7 September 2011 09:42
0
ответов
, почему CountDownLatch.getCount () возвращает long, но не int?
Я заглянул в код, все - int - параметр, переданный конструктору CountDownLatch, - int, переменная в Sync - int, тип возвращаемого значения Sync.getCount () - int. Но CountDownLatch ....
вопрос задан: 8 August 2011 17:34
0
ответов
Существует ли HashMap с методом getAndWait ()? Например. реализация BlockingConcurrentHashMap?
Многие потоки могут заполнять HashMap, в некоторых случаях мне нужно подождать (заблокировать), пока объект не появится в HashMap, например: BlockingConcurrentHashMap map = new BlockingConcurrentHashMap ();
Object x = ...
вопрос задан: 17 June 2011 16:55
0
ответов
Why does the iterator.hasNext not work with BlockingQueue?
I was trying to use the iterator methods on a BlockingQueue and discovered that hasNext() is non-blocking - i.e. it will not wait until more elements are added and will instead return false when there ...
вопрос задан: 27 May 2011 10:23
0
ответов
Поточно-ориентированная реализация max
Мне нужно реализовать сбор статистики глобального объекта для веб-сервера. У меня есть синглтон Statistics, у которого есть метод addSample (длинный образец), который впоследствии вызывает updateMax. Это должно быть ...
вопрос задан: 20 May 2011 12:43
0
ответов
Почему onRestoreInstanceState () никогда не вызывается
Я пытаюсь сохранить данные в своей деятельности, а затем восстановить их. Я сохраняю данные в onSaveInstanceState (), а затем пытаюсь восстановить данные в onRestoreInstanceState (). Я устанавливаю точку останова, метод ...
вопрос задан: 7 April 2011 00:28
0
ответов
есть ли какой-либо параллельный LinkedHashSet в JDK6.0 или других библиотеках?
мой код выдает исключение: java.util.ConcurrentModificationException в java.util.LinkedList $ ListItr.checkForComodification (LinkedList. java: 761) в java.util.LinkedList $ ListItr ....
вопрос задан: 13 March 2011 16:43
0
ответов
Как заставить один поток Java ждать результата другого потока?
Мне часто нужно, чтобы поток ждал результата другого потока. Похоже, что для этого должна быть какая-то поддержка в java.util.concurrent, но я не могу ее найти. Exchanger очень близок к ...
вопрос задан: 7 March 2011 17:13
0
ответов
Реализация BlockingQueue: В чем разница между SynchronousQueue и LinkedBlockingQueue
Я вижу эту реализацию BlockingQueue и могу ' Я понимаю разницу между ними. Мой вывод: мне никогда не понадобится SynchronousQueue
LinkedBlockingQueue обеспечивает FIFO, BlockingQueue ...
вопрос задан: 24 February 2011 10:09
0
ответов
Однопоточное выполнение задачи без очереди дальнейшие запросы
У меня есть требование, чтобы задача выполнялась асинхронно, отбрасывая любые дальнейшие запросы, пока задача не будет завершена. Синхронизация метода просто ставит задачи в очередь и не пропускает их. Я ...
вопрос задан: 10 February 2011 09:05
0
ответов
Guava MapMaker (). WeakKeys (). MakeMap () vs WeakHashMap
У нас есть сервер Scala, который получает дерево узлов используя буферы протокола через сокет, и нам нужно прикрепить дополнительные данные к каждому узлу. В однопоточном контексте и когда оба дерева узлов ...
вопрос задан: 17 November 2010 05:30
0
ответов
Есть ли недостатки у ConcurrentHashMap?
Мне нужна HashMap, доступная из нескольких потоков. Есть два простых варианта: использование обычного HashMap и синхронизация по нему или использование ConcurrentHashMap. Поскольку ConcurrentHashMap не ...
вопрос задан: 17 October 2010 02:01