ScheduledExecutorService потребляет 100% ЦП, когда corePoolSize = 0 - PullRequest
Новая
       9

ScheduledExecutorService потребляет 100% ЦП, когда corePoolSize = 0

0 голосов
/ 20 ноября 2018

Я столкнулся с интересной проблемой на производстве.

У меня был следующий ScheduledThreadPool код выделения: 

ScheduledExecutorService executorService =
            Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors() - 1);

Пул потоков обрабатывал некоторые задачи изОчередь периодически.И все работало нормально до того момента, когда служба была развернута в среде одноядерный .По-видимому, приведенная выше строка преобразована в: 

ScheduledExecutorService executorService = Executors.newScheduledThreadPool(0);

С тех пор загрузка ЦП процесса JVM постоянно составляла около 100%.В тот момент, когда я изменил Runtime.getRuntime().availableProcessors() - 1 на постоянную 1, проблема исчезла.

Потребовалось некоторое время, чтобы выяснить первопричину, но все же я не знаю причину этого.ScheduledExecutorService JavaDoc заявляет: 

/**
 * Creates a thread pool that can schedule commands to run after a
 * given delay, or to execute periodically.
 * @param corePoolSize the number of threads to keep in the pool,
 * even if they are idle
 * @return a newly created scheduled thread pool
 * @throws IllegalArgumentException if {@code corePoolSize < 0}
 */
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
    return new ScheduledThreadPoolExecutor(corePoolSize);
}

По сути, 0 (ноль) является допустимым аргументом для создания экземпляра пула потоков, но он работает очень странно с этим значением.

Может кто-нибудь объяснитьпочему так?

Простой и проверяемый контрольный пример 

import java.util.Queue;
import java.util.concurrent.*;

public class Test {

    public static void main(String[] args) throws InterruptedException {
        MessageTaskExecutor asyncEmailGatewayTaskExecutor = new MessageTaskExecutor();

        // Infinitely add new tasks to the queue every second
        for (int i = 1; ; i++) {
            System.out.println(String.format("Adding message #%s to the queue", i));

            asyncEmailGatewayTaskExecutor.putMessageIntoQueue(i);

            Thread.sleep(1_000);
        }
    }

    static class MessageTaskExecutor {

        static final int INITIAL_DELAY_SECONDS = 1;
        static final int PROCESSING_RATE_MILLISECONDS = 5_000;

        final Queue<Runnable> messageQueue = new ArrayBlockingQueue<>(1_000_000);
        final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(0);

        MessageTaskExecutor() {
            // Scavenging Message Tasks Queue every 'PROCESSING_RATE_MILLISECONDS'. Initial delay is fixed for 'INITIAL_DELAY_SECONDS'
            executorService.schedule(this::processEmailTasks, INITIAL_DELAY_SECONDS, TimeUnit.SECONDS);
        }

        void putMessageIntoQueue(int messageId) {
            Runnable messageTask = () -> System.out.println(String.format("Message #%s is getting processed!", messageId));

            messageQueue.offer(messageTask);
        }

        void processEmailTasks() {
            System.out.println(String.format("There are %s messages in the queue. Processing the messages...", messageQueue.size()));

            // Processing messages queue
            while (!messageQueue.isEmpty()) {
                executorService.submit(messageQueue.poll()); // Submitting task to executor service
            }

            // Re-scheduling processing job
            executorService.schedule(this::processEmailTasks, PROCESSING_RATE_MILLISECONDS, TimeUnit.MILLISECONDS);
        }
    }
}

Этот код выделяет ~ 30 МБ , а процесс JVM потребляет ~ 100% ЦП вклодноядерная виртуальная машина (протестирована на Win 7 / CentOS 7 ).JDK 1.8.0.181 .

Изменяя поле: 

final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(0);

на: 

final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);

Потребление ЦП снижается до нормального 3-5%.

1 Ответ

0 голосов
/ 20 ноября 2018

Это известная ошибка: JDK-8129861 .Это было исправлено в JDK 9.

Временное решение: установить размер основного пула не менее 1: 

int corePoolSize = Math.max(Runtime.getRuntime().availableProcessors() - 1, 1);
...