Вопросы с тегом 'concurrency'

Количество результатов: 3936

1 голос
1 ответ
C - несколько процессов записи на тот же файл журнала

У меня есть очень простой сервер C сокетов: основной процесс прослушивает определенный порт. При поступлении нового запроса, вилка() вызывается: дочерний процесс входи...

1 голос
2 ответа
Будет ли этот метод работы поточно-и без Разрешение блокировок

public int saveUserToMap(User user) { ReentrantLock lock; if(this.userLocks.containsKey(user.getId())) { lock = this.userLocks.get(user.getId()); }...

0 голосов
0 ответов
Запуск двух скриптов одновременно на одном исполнителя на Дженкинс

Я пытаюсь настроить тестовую среду на Дженкинс. У нас есть один исполнитель. Испытания должны: Загрузите прошивку в оболочку (которая называет TCL скрипт) и держать...

0 голосов
1 ответ
Почему все goroutines спит?

Ниже приведен код; package main import "fmt" func main() { func1(1) } func func1(n int) { ch := make(chan int) ch <- 1 for i := range ch { ...

0 голосов
1 ответ
Предотвращение текстовых файлы от удаления, когда вызывается из нескольких нитей

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

0 голосов
1 ответ
Как я могу сделать эту задержку Java вебсервис вызов использование кода меньше процессора?

Я делал некоторые процессор профилирование моего приложения, и я отмечаю, что одна из вещей, которые занимает значительное количество времени, это код, который обеспеч...

0 голосов
1 ответ
Имеет ли MySQL очереди вызовов хранимых процедур?

У меня есть хранимая процедура sp_performArchive(), который вызывает еще раз хранимые процедуры несколько. Вот так - CREATE DEFINER=`root`@`%` PROCEDURE `sp_performa...

-3 голоса
2 ответа
Почему sync.Mutex существует?

Почему sync.Mutex существует в то время как у нас есть sync.RWMutex? Я могу заблокировать/разблокировать Rw семафор. Какова главная разница между ними?

0 голосов
0 ответов
Bounded-буфер с несколькими производителями/потребителей производства/потреблением нескольких процессов

Я пытаюсь понять, как можно было бы решить проблему ограниченного буфера (семафоры), но где у нас есть несколько производителей/потребителей, где производители могут п...

0 голосов
1 ответ
Как удалить набор, который используется в качестве значения, из ConcurrentHashMap <String, Set <String >>?

Давайте рассмотрим следующий следующий код: ConcurrentHashMap&lt;String, Set&lt;String&gt;&gt; map = new ConcurrentHashMap&lt;&gt;(); // Add element: {mapKey, setVal...

0 голосов
0 ответов
Python - Pebble - непонимание функции тайм-аута

После прочтения документации галечного (вhttps://pythonhosted.org/Pebble/), Кажется, довольно просто. Тем не менее, я не могу получить ожидаемый результат. Я начал из...

2 голоса
3 ответа
Задачи процесса в партиях в asyncio

У меня есть функция, которая генерирует задачи (ИО связанных задач): def get_task(): while True: new_task = _get_task() if new_task is not None: ...

0 голосов
0 ответов
Держите ThreadPoolExecutor работает после того, как основная функция возвращает

ранее у меня есть функция, которая может быть упрощена следующим образом: Class A(): def _run(id): # do_something return def run(): for...

0 голосов
0 ответов
Как ограничить к числу разрешенных дочерних организаций в отношениях многие-к-одному?

Веб-игра... Игроки должны строить команды, они будут позже ввести сражения с. Я хочу, чтобы сохраняться воспитали команды в базе данных, по счету игрока. Тем не менее...

4 голоса
1 ответ
ConcurrentHashMap с функциональным программированием. Приостановит unsafeRun сейф?

Вопрос: Можно ли приостановить unsafeRunSync с участием IO? Например. val io: IO[Unit] = //... val io2: IO[Unit] = IO(io.unsafeRunSync) Поэтому я бы так это то, чт...

2 голоса
2 ответа
Можно ли запустить каждую задачу из пула не в синхронном режиме?

Я новичок в Ад. Я объявил мой новый тип задачи, и я хранится три из них в бассейне. Затем я хочу запустить каждую задачу в цикле. Ожидаемое поведение является то, чт...

0 голосов
1 ответ
Есть ли способ, чтобы одновременно расшифровывать большой зашифрованный файл с RSA в Java?

У меня есть 24 довольно большие RSA зашифрованных файлов, и я хочу, чтобы расшифровать их. Я использую тему расшифровать их независимо друг от друга, но я до сих пор з...

0 голосов
1 ответ
Как совместить параллелизм на основе агента с свободной монады?

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

0 голосов
2 ответа
Могу ли я рассчитывать на это, что каждый оператор обновления в PostgreSQL является атомарным?

Я читал некоторые материалы, прежде чем сказать, что каждый оператор обновления в PostgreSQL является атомарным. Например, update set column_1 = column_1 + 100 where...

3 голоса
0 ответов
Java8: ConcurrentHashMap.compute атомарность

Я пытаюсь использовать ConcurrentHashMap.compute реализовать что-то, и я не могу понять, если моя логика 100% THREADSAFE и правильно. Javadoc говорит о compute(K key, ...

0 голосов
1 ответ
Как статический HTTPClient ведет себя в параллельности ситуациях?

Я знаю, что многие уже обсуждали это раньше, и решили, что HTTPClient лучше быть созданы один раз и используются для всего приложения. У меня есть кое-какие справки об...

3 голоса
2 ответа
Java 11 HttpClient http2 Слишком много потоков ошибок

Я использую HttpClient ява 11, чтобы отправить запрос на сервер http2. HttpClient объект создаются как боб Синглтон Spring, как показано ниже. @Bean public HttpCl...

0 голосов
0 ответов
Является ли ДООСНАСТКА в `Зов :: execute` потокобезопасным?

Так что я действительно не люблю обратный вызов аспект из Call::enqueue. Я бы много, а обернуть вызов Call::execute в а Future. Насколько это безопасно, чтобы сделат...

0 голосов
0 ответов
Параллельное выбрать в SQLite очень медленно

Когда я выполнить запрос SELECT, на одной базе данных SQLite, скорость чтения с моей ГНБ досягаемости почти ~ 200 МБ/с. Когда я пытаюсь открыть 8 SQLite файлов одновре...

0 голосов
1 ответ
Может ли Google Apps Script Web App масштабируемым?

Я разрабатываю приложение Google Apps Script Web App. Это веб-приложение является следующей версией FlipVideo, сценарий, который я ранее разработанным в Листе Google (...

0 голосов
1 ответ
Асинхронный исполнитель не прекращает процесс после запуска

Я хотел бы иметь бассейн процесса в основном асинхронном приложениях I/O, потому что иногда ЦП задача должна быть сделано, что не следует застопорить основное приложен...

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

я должен увеличивать столбец в базе данных, этот прирост может зависеть другой столбец, например, приращение по пользователю, i'am с помощью JMeter отправить несколько...

4 голоса
2 ответа
Глобально изменяемый объект разделен между несколькими процессами и модулями

проблема Я пишу часть программного обеспечения, в котором я хотел бы разделить объект от определенного модуля. Этот объект должен быть изменяемым из различных модулей...

1 голос
1 ответ
Подключение Phoenix/Erlang узел

У меня есть узел Эликсир Феникс начал на одной машине и узлом Erlang на другой. Узел Эрланга имеет процесс с именем «REC», который принимает кортеж из трех элементов: ...

0 голосов
0 ответов
Почему rxjava потребляют поток для ввода/вывода

В модели цикла событий для асинхронного, цикл обработки событий имеет только один поток, который слушает ответ от операций ввода/вывода. Это позволяет цикл обработки с...

0 голосов
1 ответ
Использование библиотеки запросов в on_failure или on_sucesss крючка вызывает задачу повторить попытку на неопределенное время

Это то, что у меня есть: import youtube_dl # in case this matters class ErrorCatchingTask(Task): # Request = CustomRequest def on_failure(self, exc, task_id,...

0 голосов
1 ответ
C# с Monitor Коллекция была изменена; операции перечисления не может выполнить

Я выполняю простую операцию получения столбца из DataTable. После выполнения этой операции в среде нитки, я столкнулся исключение. Тем не менее, я добавил мониторы, чт...

10 голосов
3 ответа
Java - Distributed JPA Блокировка для резервирования

Я работаю над унаследованной системой, которая позволяет планировать резервирование. Приложение является лицом без гражданства REST и предназначен для горизонтально ма...

1 голос
0 ответов
Бенчмаркинг стопорного свободного стека с Java и JMH

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

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

Я читаю книгу «Искусство программирования многопроцессорного Мориса Херлиха и Нир Шавит и пытаюсь понять, в главе 3 о Параллельных объектах» Линеаризуемость: «Осно...

1 голос
1 ответ
Автоматизировать последовательные целые идентификаторы без использования спецификации идентичности?

Существуют ли какие-либо пробовали/истинные методы управления собственным последовательное целое поле без использования SQL Server встроенный в спецификации идентичнос...

4 голоса
1 ответ
Программа многопоточности Java

Моя задача состоит в том, чтобы создать программу, которая есть: Класс Client Класс Gate Класс Museum Client входит и оставляя Museum путем использования Gate кла...

0 голосов
1 ответ
Что одновременно ошибка в этой программе?

У меня есть одна программы с странномом по совместительству ошибки. Что эта программа делает: Выполнить каждый цикл событий EVENT_LOOP_PAUSE_DURATION_IN_MS. Для каж...

1 голос
3 ответа
почему существует цикл в то время как положить() из LinkedBlockingQueue

public void put(E e) throws InterruptedException { if (e == null) throw new NullPointerException(); int c = -1; Node&lt;E&gt; node = new Node&lt;E&gt;(e); ...

0 голосов
0 ответов
MongoDB: читать и блокировать документ, прежде чем писать

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

0 голосов
1 ответ
и условные нити переменных

Я следую учебник по PTHREAD от вот. #include &lt;stdio.h&gt; #include &lt;stdlib.h&gt; #include &lt;pthread.h&gt; pthread_mutex_t count_mutex = PTHREAD_MUTEX_IN...

0 голосов
0 ответов
Owin WebAPI Максимальное количество одновременных подключений

public IHttpActionResult TestSpeed() { Sleep(10000); } Названный выше API, одновременно, можно управлять только выжать около 16 соединений в течение 12 секунд. ...

0 голосов
0 ответов
Асинхронный против Concurrent?

Не ясно, когда и если не использовать асинхронные операции в C++ (и каковы бы ни были эти языки). Любые учебники доступны в Интернете? Извините, если это супер наивный...

0 голосов
0 ответов
Singleton EJB Управление параллелизмом и EJB Timer Service - Выполнение методов для чтения и записи

Ниже мой Singleton EJB, который использует Bean Managed Параллелизм: import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import ja...

2 голоса
1 ответ
Выполнить ограниченное число задач одновременно

Учитывая, у меня есть IEnumerable&lt;Func&lt;Task&gt;&gt; чтобы сгенерировать (искатель) -Tasks, которые я хочу выполнить одновременно, как я могу установить верхнюю г...

0 голосов
1 ответ
Повышение TimeoutError: [ERRNO 110] Время соединения в то время sockt.send_all (запрос)

параметры сокета клиента: s = socket.create_connection(self._addr, timeout=15) s.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) s.setsockopt(socket.SOL_TCP,...

10 голосов
1 ответ
Условно определим синхронизированный блок

Скажем, у меня есть метод: public void run(){ synchronized(this.foo){ } } но иногда, когда я запускаю этот метод, мне не нужно синхронизировать на что-либо. Чт...

0 голосов
0 ответов
Очередь Параллельное Blocking

Я пытаюсь решить проблему производитель-потребитель, но я хочу, чтобы мой поток-потребитель блокировать, пока данные не станет доступным. У меня есть несколько потоков...

1 голос
0 ответов
Как я могу использовать subprocess.Popen питона с одним входным CSV и один ряд для каждого процесса на вход?

Я хотел бы запустить несколько экземпляров питона сценария при вводе переменных класса экземпляра в каждом сценарии в качестве одной строки CSV в экземпляре. Например...

1 голос
1 ответ
Понимание поведения сливаются Gremlin в одновременной среде

Следующий запрос добавляет ребро между двумя вершинами, только если она не существует. g.V('ea36e68a-70c5-4d38-a038-f5145ed4ced7').as('v'). V('e3516889-7df0-4cc9-b2...

1 2 3 4 5 6 7 8 ... 78 79 right