Вопросы с тегом «concurrency»

82
Решение неприятно параллельных проблем с использованием многопроцессорной обработки Python

Как можно использовать многопроцессорность для решения неприятно параллельных задач ? Ужасно параллельные проблемы обычно состоят из трех основных частей: Чтение входных данных (из файла, базы данных, TCP-соединения и т. Д.). Выполните вычисления с входными данными, при этом каждый расчет не...

79
Когда ConcurrentDictionary TryRemove вернет false

Будет ли он возвращать false только в том случае, если словарь не содержит значения для данного ключа, или он также вернет false из-за условий гонки потоков, например, другой поток добавляет / обновляет что-то? Вопрос в коде: ConcurrentDictionary<int, string> cd = new...

79
Координация параллельного выполнения в node.js

Модель программирования node.js, управляемая событиями, несколько усложняет координацию выполнения программы. Простое последовательное выполнение превращается во вложенные обратные вызовы, что достаточно легко (хотя и немного запутано для записи). Но как насчет параллельного выполнения? Скажем, у...

18
Для чего используются заборы памяти в Java?

Пытаясь понять, как SubmissionPublisher( исходный код в Java SE 10, OpenJDK | docs ), новый класс, добавленный в Java SE в версии 9, был реализован, я наткнулся на несколько вызовов API, о которых VarHandleраньше не знал: fullFence, acquireFence, releaseFence, loadLoadFenceИ storeStoreFence....

12
Служба Java Stop Executor, если одна из назначенных ему задач по какой-либо причине не выполняется

Мне нужен какой-то сервис, который будет запускать несколько задач одновременно и с интервалом в 1 секунду в течение 1 минуты. Если одна из задач не выполняется, я хочу остановить службу и все задачи, которые выполнялись вместе с каким-то индикатором, что что-то пошло не так, иначе, если через одну...

10
Kotlin сопрограммы «случается раньше» гарантирует?

Предоставляют ли сопрограммы Kotlin какие-либо гарантии «произойдет раньше»? Например, существует ли гарантия «происходит до» между записью в mutableVarи последующим чтением (потенциально) в другом потоке в этом случае: suspend fun doSomething() { var mutableVar = 0 withContext(Dispatchers.IO) {...

9
Безопасно ли для параллелизма вызывать concurrency :: concurrent_vector :: push_back при переборе этого concurrent_vector в другом потоке?

push_back , begin , end описаны как параллельный сейф в https://docs.microsoft.com/en-us/cpp/parallel/concrt/reference/concurrent-vector-class?view=vs-2019#push_back Однако приведенный ниже код утверждает. Возможно, потому что элемент добавлен, но еще не инициализирован. struct MyData { explicit...

9
Что гарантировано с C ++ std :: atomic на уровне программиста?

Я выслушал и прочитал несколько статей, выступлений и вопросов о стековом потоке std::atomicи хотел бы быть уверен, что хорошо это понял. Потому что я все еще немного запутался с видимостью записи строк кэша из-за возможных задержек в протоколах когерентности кэша MESI (или производных), буферах...

9
Параллельное «любое» или «все» в Haskell

Шаблон, с которым я сталкивался несколько раз, - это тот, в котором список значений должен быть проверен путем сопоставления некоторого теста и проверки, прошел ли какой-либо или все элементы. Типичное решение - просто использовать удобные встроенные функции allи any. Проблема в том, что они...