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

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

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

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

Наконец, если вы хотите суммировать много чисел, вам не нужно сохранять их и суммировать позже. Вы можете суммировать их, как вы идете.

аюсь выполнить простой расчет (это вызываетMath.random() 10000000 раз). Удивительно, но запуск его простым способом выполняется намного быстрее, чем при использовании ExecutorService. Я прочитал другую ветку наУдивительная точка безубыточности ...

Исполнитель и демон в Java

У меня есть объект MyThread, который я создаю, когда мое приложение загружается через сервер, я отмечаю его как поток Daemon и затем вызываю

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

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

Как правильно отлавливать RuntimeExceptions от Executors?

Скажи, что у меня есть следующий код:

Запуск задачи параллельно другой задаче

Как правильно отлавливать RuntimeExceptions от Executors?

Скажи, что у меня есть следующий код: ExecutorService executor = Executors.newSingleThreadExecutor(); executor.execute(myRunnable);Сейчас еслиmyRunnable бросаетRuntimeExcpetionкак я могу поймать это? Одним из способов было бы поставить ...

Разница между Executors.newFixedThreadPool (1) и Executors.newSingleThreadExecutor ()

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

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