1
ответ

Golang context.WithValue: как добавить несколько пар ключ-значение

С помощью пакета контекста Go можно передавать специфичные для запроса данные в стек функций обработки запросов, используя func WithValue (parent Context, key, val interface {}) Context Это создает ...
вопрос задан: 8 February 2019 20:44
1
ответ

Тупик при использовании SELECT FOR UPDATE

Я заметил, что параллельное выполнение простых и идентичных запросов похоже на BEGIN; ВЫБРАТЬ files.data ИЗ файлов, где files.file_id = 123 LIMIT 1 FOR UPDATE; ОБНОВЛЕНИЕ файлов УСТАНОВЛЕНО ... ГДЕ файлы ....
вопрос задан: 21 January 2019 02:01
1
ответ

Шаблон для удаления элементов из параллельной очереди после просмотра

У меня один производитель и несколько потребителей. Я использую ConcurrentQueue. Я использую C #, но я думаю, что моя проблема - языковая независимость. Там могут быть неуникальные потребители. то есть больше чем один потребитель ...
вопрос задан: 20 January 2019 07:06
1
ответ

C # фиксированный размер ConcurrentQueue получить элемент по индексу

Я нашел старый код, который реализует потокобезопасную очередь. и я попытался создать новую реализацию, используя открытый класс ConcurrentQueue старого класса BoundedQueue < T > где T: класс {...
вопрос задан: 18 January 2019 22:26
1
ответ

Долгосрочная задача, не имеющая доступа к консоли?

Я пишу приложение-> Очередь -> Потребитель -> Очередь2 -> Потребитель2. У меня есть Потребитель2, ожидающий получения списка порогового значения, затем запускаю другую задачу, имитирующую долго выполняющуюся задачу (например, ...
вопрос задан: 18 January 2019 19:52
1
ответ

Как исправить & ldquo; одну проблему при проверке состояния гонки с помощью инструментов go-build-race & rdquo ;?

Сначала я знаю, что в коде есть какое-то состояние гонки, поэтому я использовал команду «go build -race», чтобы проверить его, и я хочу увидеть, как результат показывает, что при первом запуске он показывает один результат как ...
вопрос задан: 18 January 2019 07:32
1
ответ

Параллелизм в Android

У меня есть случай, как 2 идентификатора продаж собираются заказать товар в то же время с другой суммой БД (любая БД) должна автоматически делать математику по количеству товара. Скажем, мой текущий запас ...
вопрос задан: 18 January 2019 04:08
1
ответ

Axios множественный запрос на перехватчик

Я использую библиотеку axios в своем приложении реакции. У меня проблема с перехватчиком. Мой вопрос, скажем, у меня есть три запроса одновременно, и у меня нет токена, ...
вопрос задан: 17 January 2019 18:41
1
ответ

Как охватить MaxDegreeOfParallelism между несколькими блоками TPL DataFlow?

Я хочу ограничить общее количество запросов, которые я отправляю на сервер базы данных по всем блокам DataFlow, до 30. В следующем сценарии регулирование 30 одновременных задач происходит в каждом блоке, поэтому ...
вопрос задан: 17 January 2019 15:42
1
ответ

Execute_concurrent Кассандры не работает должным образом

Я написал скрипт на Python, который читает csv и вставляет их в таблицу Cassandra, используя как асинхронный, так и параллельный режим, но параллельный медленнее асинхронного. Моя цель использовать одновременное было достичь ...
вопрос задан: 17 January 2019 10:17
1
ответ

Объединить два канала закрытия

Есть два канала, которые будут использоваться для сигнализации путем их закрытия. Как сделать из них один канал, который будет закрыт, если хотя бы один из них закрыт. Этот код иллюстрирует то, что я хотел бы ...
вопрос задан: 17 January 2019 10:02
1
ответ

Как часто мы должны использовать фьючерсов и актеров? Есть альтернативы? [закрыто]

Я решил создать физический движок с помощью scala, используя параллелизм. Я знаю, что для большого числа вычислений можно распараллелить (что важно для оптимизации вещей). Однако я знаю ...
вопрос задан: 16 January 2019 07:58
1
ответ

Поиск URL-адреса LDAP?

Я хочу получить доступ к Active Directory на сервере компании, чтобы я мог написать простую программу телефонной книги. Казалось бы, мне нужно использовать LDAP для подключения к нему, чтобы получить набор записей. Есть ли ...
вопрос задан: 11 December 2018 18:30
1
ответ

Таблица Cache Cassandra в приложении scala

Мне нужно получить некоторые данные из Cassandra для записей в потоковом приложении Kafka-Streams. Мне нужно будет выполнить присоединение к ID. Я хотел бы настроить кеш, чтобы сэкономить время, используемое для запросов. Стол ...
вопрос задан: 13 July 2018 12:48
1
ответ

Порядок выполнения вызовов не согласован

У меня есть этот код, где я выполняю наборы вызовов, мне нужен один набор, чтобы завершить все его работу, прежде чем запускать следующий набор. Этот код работает нормально, но иногда следующий набор начнет работать ...
вопрос задан: 13 July 2018 09:51
1
ответ

Передать несколько параметров в concurrent.futures.Executor.map?

Concurrent.futures.Executor.map принимает переменное количество итераций, из которых вызывается данная функция. Как мне его назвать, если у меня есть генератор, который производит кортежи, которые обычно ...
вопрос задан: 8 April 2018 17:37
1
ответ

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

Как делает один модульный тест, что новый поток был порожден для Выполнимой задачи при использовании ExecutorService? В основном у меня есть статический пул потоков для моего приложения. общедоступный статический заключительный ExecutorService...
вопрос задан: 11 January 2018 21:33
1
ответ

Нарушение параллелизма: UpdateCommand влиял на 0 из ожидаемой 1 записи

Вот код, какие-либо идеи, почему я получаю эту ошибку? частный SQLiteDataAdapter DA_Webfiles;//соединение Установки, заполните набор данных и т.д. DataTable dt = this.dataSet. Таблицы ["WEBFILES"]; DataRow newRow = dt....
вопрос задан: 6 August 2017 10:57
1
ответ

LINQ К исключению SQL с Присоединением (): не Может добавить объект с ключом, который уже используется

Рассмотрите этот типичный разъединенный сценарий: загрузитесь Клиентский объект от SQL Server с помощью LINQ Для пользователя SQL редактирует объект, и уровень представления передает обратно измененный объект. слой данных...
вопрос задан: 5 August 2017 10:32
1
ответ

Как нужно обработать javax.persistence. OptimisticLockException?

Я плохо знаком с JPA, так простите мне не будучи ясными. В основном я хочу предотвратить параллельные модификации при помощи Оптимистической Блокировки. Я добавил, что @Version приписывают моему классу объекта. Я должен...
вопрос задан: 23 May 2017 12:23
1
ответ

Scala final vs val для видимости параллелизма

В Java при использовании объекта в нескольких потоках (и в целом) рекомендуется делать поля окончательными. Например, открытый класс ShareMe {private final MyObject obj; public ...
вопрос задан: 23 May 2017 11:54
1
ответ

Почему ThreadGroup критикуется?

Я знаю о существующей практике использования Исполнителей вместо ThreadGroup: обычно предпочтительный способ иметь дело с Потоками, ловя исключения из потоков, и т.д... Однако что является свойственными дефектами...
вопрос задан: 23 May 2017 11:46
1
ответ

Предотвращение нескольких вторичных заселений того же региона кэша (из-за параллелизма)

У меня есть веб-сайт интенсивного трафика, и я использую, в спящем режиме. Я также использую ehcache для кэширования некоторых объектов и запросов, которые требуются, чтобы генерировать страницы. Проблемой являются "параллельные неудачные обращения в
вопрос задан: 23 May 2017 10:30
1
ответ

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

Мой вопрос относится к тому, гарантирует ли использование ReentrantLock видимость поля в том же уважении, которое обеспечивает синхронизируемое ключевое слово. Например, в следующем классе A...
вопрос задан: 10 May 2017 09:21
1
ответ

python подклассификация multiprocessing.Process

Я новичок в объектно-ориентированном python, и я переписываю свое существующее приложение в объектно-ориентированную версию, потому что сейчас разработчиков становится все больше, и мой код становится не обслуживаемым. Обычно я ...
вопрос задан: 25 January 2017 22:01
1
ответ

ConcurrentHashSet в Scala [дубликат]

Я использую ConcurrentHashMap для создания Set ConcurrentHashMap.newKeySet [String] (), и я хотел преобразовать его в коллекцию Scala. Итак, сделаем следующее: ConcurrentHashMap.newKeySet [String] (). AsScala работает, ...
вопрос задан: 6 December 2016 12:35
1
ответ

Обрабатывание исключений для ThreadPoolExecutor

У меня есть следующий фрагмент кода, который в основном сканирует через список задачи, которая должна быть выполнена, и каждая задача затем дана исполнителю для выполнения. JobExecutor в свою очередь создает...
вопрос задан: 25 April 2016 17:15
1
ответ

ConcurrentModificationException несмотря на синхронизируемое использование

общественность синхронизировала X getAnotherX () {если (iterator.hasNext ()) {X b = iterator.next (); Имя строки = b.getInputFileName ();... возвратите b;} еще {возвращают пустой указатель; }} несмотря на...
вопрос задан: 22 January 2016 15:55
1
ответ

Модели параллелизма в nodejs

Кто-нибудь знает, что такое модели памяти и потоковой передачи в nodejs? В частности, является ли ii ++ атомарным? Он ведет себя так, как если бы ii был изменчивым в Java 1.5, в Java 1.4, на C, или вообще не работал?
вопрос задан: 20 January 2016 14:09
1
ответ

Реализация BufferedIterator

Кто-то знает о BufferedIterator с открытым исходным кодом, где следующие элементы N нетерпеливо выбираются на фоновом потоке? Вот реализация из статьи TechRepublic, но я предполагаю, что она имеет...
вопрос задан: 20 August 2015 04:43