Результаты поиска по запросу "concurrency"
Пружинный поток / раскол после шага
Я строю решение для подпружиненных партий, которое содержит следующий процесс: шаг 1: разбить список на несколько списков шаг 2: обработать каждый подсписок шаг 3: объединить подсписки Сгенерированные подсписки могут обрабатываться параллельно, ...
При каких условиях BlockingQueue.take выбрасывает прерванное исключение?
Давайте предположим, что у меня есть поток, который потребляет элементы, созданные другим потоком. Его метод запуска следующий: inQueue - BlockingQueue boolean shutdown = false; while (!shutdown) { try { WorkItem w = inQueue.take(); w.consume(); ...
имеет атомарную очистку, но также позволяет быстро проверить, существует ли ключ. «Быстро» - это, конечно, относительный термин, но в зависимости от вашего использования это может быть быстрее, чем перечисление большого стека.
чиститьConcurrentBag? это не имеет никакого метода, какClear или жеRemoveAll...
, Это исправлено в следующих выпусках: JDK 8u201, JDK 11.0.2 и JDK 12.
НИЕ:это не дубликат, пожалуйста, прочитайте темусarefully https://stackoverflow.com/users/3448419/apangin [https://stackoverflow.com/users/3448419/apangin]цитата: Реальный вопрос заключается в том, почему код иногда работает, когда он ...
быть каким-то образом случившимся до того, как между исходной записью и чтением в противном случае нет никакой гарантии, что что-либо, кроме значения по умолчанию, будет видно. В то время как на архитектурах x86 вы обычно видите что-то, что отличается от любой гарантии.
у меня есть экземпляр HashSet после запуска через Collections.unmodifiableSet (), является ли он потокобезопасным? Я спрашиваю об этом, поскольку документация Set утверждает, что это не так, но я выполняю только операции чтения.
, Таким образом, вы можете указать, что получатель работает как отдельный процесс и не привязан к основному потоку пользовательского интерфейса.
у меня есть внутренний класс, который расширяетсяBroadcastReceiver в моемService класс, я должен заботиться о синхронизации, когдаBroadcastReceiver класс читает / пишет в объекты изService класс? Или, ...
Это Java, так что поток все еще может быть прерван - в моем случае я пишу библиотеку, которая могла бы использоваться Akka или Vertx или любым другим Java env. Поэтому я ищу общее решение. Отсюда и вопрос.
, что у меня есть это: public void foo(){ CompletableFuture.delayedExecutor(1, TimeUnit.MILLISECONDS).execute(() -> { doSomethingA(); }); doSomethingB(); }Есть ли гарантия, что doSomethingB (); всегда будет выполняться до doSomethingA () ...
Для быстрого решения, maven зависимость приведена ниже:
елAtomicInteger, AtomicLong, но гдеAtomicFloat (или жеAtomicDouble)? Может быть, есть какая-то хитрость?
@ user310291 Вы должны определенно установить это как ответ на данный момент
ли что-то эквивалентноеAkka [http://akka.io/]но для .NET? http://doc.akka.io/use-cases [http://doc.akka.io/use-cases]
Документация Java по ReadWriteLock
тим, я программирую в рамках потоков, который не имеетмьютексы с несколькими программами чтения / записи [https://secure.wikimedia.org/wikipedia/en/wiki/Readers-writer_lock], Могу ли я реализовать их функциональность с помощью ...