concurrency

0зной

1ответ

Как отменить асинхронное вычисление в любое время?

Мне нужно выполнить сложные вычисления async и уметь прерывать их в любое время (из-за пределов вычислений). В текущей реализации используется scala.concurrent.Future для запуска вычислений. Однако, п

0зной

2ответ

Самый простой способ использовать обратный вызов i/o в параллельном http-kit/get экземплярах

Я запускаю несколько сотен параллельных запросов http-kit.client/get, снабженных обратным вызовом для записи результатов в один файл. Что было бы хорошим способом борьбы с потоками? С использованием c

1зной

1ответ

Как определить, что предотвращает использование нескольких ядер в golang?

Итак, у меня есть часть кода, которая является параллельной, и она предназначена для запуска на каждый процессор/ядро. Есть два больших входных векторов с выходными значениями var ( input = make([

1зной

1ответ

Есть ли резервная копия python 2 для пакета concurrency.futures из python 3

Я бы хотел использовать красивые исполнители и API-интерфейсы потоков, но я ограничен средой Python 2. Я не могу перейти на Python 3 из-за другой зависимости от третьей стороны. Ближайший ответ я наше

0зной

1ответ

Что эквивалентно однопоточному ExecutorService в RxJava?

Я хотел бы использовать RxJava вместо моего однотридовой ExecutorService: private ExecutorService executor = Executors.newSingleThreadExecutor(); executor.submit(/* ... */); Я задавался вопросом, ч

0зной

1ответ

Spark Прямой поток параллельного ограничения работы

Я запускаю прямой поток искры от kafka, где мне нужно запустить много параллельных заданий, чтобы обрабатывать все данные во времени. В искры вы можете установить spark.streaming.concurrentJobs на нес

-2зной

1ответ

Рамка выполнения темы/задачи в Java

Предположим, у меня есть 5 задач a, b, c, d и e. Задачи b c d зависят от a и e, зависит от e, 5 задач состоят из DAG. Интуитивно задача b c d должна выполняться параллельно. Может ли любая библиотека