3
ответа

Как заставить ThreadPoolExecutor отправить () блок метода, если он насыщается?

Я хочу создать ThreadPoolExecutor, таким образом, что, когда он достиг, его максимальный размер и очередь полны, отправление () блоки метода при попытке добавить новые задачи. Сделайте я должен реализовать пользовательское...
вопрос задан: 20 March 2019 04:06
3
ответа

Какую параллельную реализацию Очереди я должен использовать в Java?

От JavaDocs: ConcurrentLinkedQueue является соответствующим выбором, когда много потоков совместно используют доступ к общему набору. Эта очередь не разрешает пустые элементы. ArrayBlockingQueue...
вопрос задан: 8 November 2018 09:10
3
ответа

ExecutorService, стандартный способ постараться не определять задачу для очереди, становящейся слишком полной

Я использую ExecutorService для простоты параллельной многопоточной программы. Возьмите следующий код: в то время как (xxx) {экс-услуги ExecutorService = Executors.newFixedThreadPool (NUMBER_THREADS);......
вопрос задан: 10 October 2018 18:53
3
ответа

C# параллельные вопросы о списке

У меня есть ситуация в C#, где у меня есть список простых типов. К этому списку могут получить доступ несколько потоков: записи могут быть добавлены или удалены, и существование записи может быть проверено. Я имею...
вопрос задан: 24 September 2018 13:09
3
ответа

Существует ли существующее решение для этих конкретных многопоточных требований структуры данных?

У меня была потребность в многопоточной структуре данных, которая поддерживает эти требования: Позволяет нескольким параллельным читателям, и устройства записи отсортирован, легко рассуждать о Выполнении нескольких читателей и один...
вопрос задан: 18 July 2018 15:40
3
ответа

Java - когда использовать, уведомляет или notifyAll? [дубликат]

Почему делает java.lang. Объект имеет два, уведомляют, что методы - уведомляют и notifyAll? Кажется, что notifyAll делает по крайней мере все уведомляет, делает, итак, почему не просто используют notifyAll все время? Если notifyAll используется...
вопрос задан: 26 November 2017 21:22
3
ответа

Динамическое изменение размеров java.util.concurrent. ThreadPoolExecutor, в то время как это имеет ожидающие задачи

Я работаю с java.util.concurrent. ThreadPoolExecutor для обработки многих объектов параллельно. Хотя поточная обработка себя хорошо работает, время от времени мы сталкивались с другими ограничениями ресурсов из-за...
вопрос задан: 26 November 2017 16:20
3
ответа

Задача Таймера Java, как гарантируют, не будет работать одновременно?

новый Таймер (...) .schedule (задача) Является задачей, которая, как гарантируют, будет выполнена единственным потоком в любой момент времени?
вопрос задан: 2 August 2017 17:16
3
ответа

Агенты Scala могут обработать несколько сообщений одновременно?

Ответ на недавний мой вопрос указал, что агент обработал свои сообщения по одному. Действительно ли это верно? Я не вижу ничего, что явно говорит, что (в Программировании в Scala), который содержит...
вопрос задан: 23 May 2017 12:19
3
ответа

Блокирование Очереди - Потребность больше информации

Этот вопрос связан с одним из моих более ранних вопросов.. Предыдущее Сообщение Там блокирующаяся природа упоминается как преимущество. Я пытался разработать некоторый простой код для демонстрации блокирования...
вопрос задан: 23 May 2017 12:06
3
ответа

Как ограничить параллелизм при использовании агентов в Scala?

Я происхожу из Java, где я отправил бы Runnables ExecutorService, поддержанному пулом потоков. Очень ясно в Java, как установить пределы к размеру пула потоков. Я интересуюсь использованием Scala...
вопрос задан: 23 May 2017 12:06
3
ответа

LinkedBlockingQueue по сравнению с ConcurrentLinkedQueue

Мой вопрос касается этого вопроса, который задают ранее. В ситуациях, где я использую очередь для коммуникации между потоками производителя и потребителя, был бы люди обычно рекомендовать использовать...
вопрос задан: 23 May 2017 11:54
3
ответа

Как продемонстрировать условия состязания вокруг значений, которые не публикуются правильно?

Я читаю "Параллелизм Java на практике" и смотрю на пример кода на странице 51. Согласно книге эта часть кода из-за опасности отказа, если это не было опубликовано правильно...
вопрос задан: 23 May 2017 02:03
3
ответа

Являются ли транзакции MySQL InnoDB сериализуемыми / атомными? [Дубликат]

Я смущен независимо от того, являются ли транзакции MySQL сериализуемыми и защищены ли от чтения аномалии? Например, что, если я ВЫБРАТЬ значение из строки, а затем ОБНОВЛЯЮТ эту строку ...
вопрос задан: 3 June 2016 00:09
3
ответа

Что такое монитор в Java?

Что монитор упомянут в параллельном программировании в Java? Когда я считал, что "каждый объект связал монитор", что делает это означающий? Действительно ли это - специальный объект?
вопрос задан: 16 December 2015 14:03
3
ответа

Хороший пример динамической взаимоблокировки?

Я понимаю, какова динамическая взаимоблокировка, но я задавался вопросом, был ли у кого-либо хороший основанный на коде пример ее? И основанным на коде, я не имею в виду "двух человек, пытающихся закончить друг друга в коридоре". Если я читал...
вопрос задан: 8 December 2015 22:06
3
ответа

Как я могу постараться не блокироваться с Java ServerSocket?

Я работаю над слушателем сокета, который должен послушать на 2 портах для 2 типов данных (порт 80 и порт 81). Эти данные очень похожи как в виде операций, которые выполняются на данных и являются...
вопрос задан: 29 May 2015 17:07
3
ответа

При помещении потока для сна, пока не происходит событие X

Я пишу во многие файлы в потоковом приложении, и я создаю один обработчик на файл. У меня есть класс HandlerFactory, который справляется с распределением этих обработчиков. То, что я хотел бы сделать, то, что поток...
вопрос задан: 30 April 2015 19:18
3
ответа

Реализация параллельного LinkedHashMap

Я пытаюсь создать параллельный LinkedHashMap для многопоточной архитектуры. Если бы я использую Collections#synchronizedMap (), я должен был бы использовать синхронизируемые блоки для повторения. Эта реализация...
вопрос задан: 4 March 2015 07:21
3
ответа

Гуава MultiMap и ConcurrentModificationException [дубликат]

Я не понимаю, почему я получаю ConcurrentModificationException, когда я выполняю итерации через эту мультикарту. Я считал следующую запись, но я не уверен, понял ли я все это. Я пытался добавить...
вопрос задан: 11 June 2014 13:51
3
ответа

Семафор JavaScript / тест-и-набор / блокировка?

Действительно ли там такая вещь как атомарный тест-и-набор, семафор, или привяжите JavaScript? У меня есть JavaScript, вызывающий асинхронные фоновые процессы с помощью пользовательского протокола (фоновый процесс буквально работает...
вопрос задан: 28 April 2014 03:20
3
ответа

Java энергозависимая ссылка по сравнению с AtomicReference

Есть ли какое-либо различие между энергозависимой Ссылкой на объект и AtomicReference в случае, если я просто использовал бы, получают () и устанавливают () - методы от AtomicReference?
вопрос задан: 14 February 2014 17:21
3
ответа

Отправка последовательной очереди, которая является асинхронной [дубликат]

Я изучал параллелизм и сериализованную очередь на iOS. Одна вещь, которую я просто не могу понять, - это то, как Serialized Dispatch queue с асинхронным отличается от Serialized Dispatch ...
вопрос задан: 6 November 2013 22:59
3
ответа

Как перехватывать исключения в FutureTask

Обнаружив, что FutureTask, запущенный в Executors.newCachedThreadPool () на Java 1.6 (и из Eclipse), проглатывает исключения в Runnable. Метод run (), я попытался найти способ поймать ...
вопрос задан: 26 July 2013 08:18
3
ответа

Шаблоны разработки для параллельного программирования? [закрытый]

Которые являются самыми соответствующими шаблонами разработки для ориентированных на параллелизм языков программирования?
вопрос задан: 6 July 2013 20:35
3
ответа

Java параллельный и параллельный GC

Эта статья здесь предлагает использовать-XX: + UseParNewGC, "Чтобы включить параллельному молодому поколению GC с параллельным GC". Мой беспорядок состоит в том, что для включения и параллельного и параллельного GC, должен...
вопрос задан: 3 June 2013 15:22
3
ответа

BlockingQueue - заблокированный drainTo () методы

BlockingQueue имеет метод, названный drainTo (), но он не заблокирован. Мне нужна очередь, которую я хочу заблокировать, но также и способный получить поставленные в очередь объекты в отдельном методе. Возразите сначала = blockingQueue....
вопрос задан: 15 May 2013 17:54
3
ответа

Что такое хороший шаблон для использования Глобального Взаимного исключения в C#?

Взаимоисключающий класс является очень недооцененными, и Глобальными взаимными исключениями еще больше. Что хороший, безопасный шаблон должен использовать при создании Глобальных взаимных исключений? Тот, который будет работать Независимо от локали моя ма
вопрос задан: 1 February 2013 13:46
3
ответа

Для двух ExecutorServices действительно ли возможно совместно использовать пул потоков?

У меня есть набор записей на процесс, и обработка может быть параллелизирована, таким образом, я создал ExecutorService (через Executors#newCachedThreadPool ()). Обработка отдельной записи...
вопрос задан: 6 November 2012 08:11
3
ответа

Когда делает вызов (), метод называют в Исполнителе Java, использующем Вызываемые объекты?

Это - некоторый пример кода от примера. То, что я должен знать, - когда к вызову () обращаются вызываемое? Что инициировало его? общедоступный класс CallableExample {общедоступный статический класс WordLengthCallable...
вопрос задан: 31 July 2012 02:27