Как рабочие места назначаются исполнителям в Spark Streaming?

Допустим, у меня есть 2 или более исполнителей в приложении Spark Streaming.Я установил время пакетной обработки в 10 секунд, поэтому каждые 10 секунд задани...

Несколько потоков, пишущих в один и тот же CSV в Python

Я новичок в многопоточности в Python и в настоящее время пишу скрипт, который добавляется в CSV-файл. Если бы я должен был иметь несколько тем, представленны...

 так что, конечно, он может быть подключен автоматически.

истемная диаграмма прилагается. Системная диаграмма [https://i.stack.imgur.com/tEZYn.png] КАК РАБОТАЕТ ПОТОК: Пружинный поток интеграции читает входные данные из файла json на C: \ и выполняет 2 действия: Хранить в БД Уведомить / распечатать ...

Если вы хотите, чтобы другой поток выполнил задачу, вы можете использовать ExecutorService и предоставить ему то, что вы хотите сделать. В приведенном здесь примере вы можете просто выполнить в run () то, что сделает второй поток.

ользуюScheduledExecutorService выполнить задачу, которая вызывает услугу по фиксированной ставке. Служба может вернуть некоторые данные в задачу. Задача хранит данные в очереди. Некоторые другие потоки медленно выбирают элементы ...

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

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

Элегантная реализация индикаторов длины очереди в ExecutorServices

asyncio: возможно ли отменить будущее, выполненное Исполнителем?

Я хотел бы запустить блокирующую функцию в Executor с помощью вызова asyncio loop.run_in_executor, а затем отменить ее позже, но, похоже, это не работает для...

Как рекурсия завершения исполнителя в Java?

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

Вызов Looper более одного раза вызывает «отправку сообщения обработчику в мертвой ветке»

Я использую Executor [фиксированный пул потоков] с моей собственной ThreadFactory, которая добавляет Looper:

Как остановить запуск следующего потока в ScheduledThreadPoolExecutor

У меня есть ScheduledThreadPoolExecutor, который имеет один поток и работает каждые 30 секунд.Теперь, если текущий исполняющий поток выдает какое-то исключен...